Package | Description |
---|---|
org.pentaho.di.core.listeners | |
org.pentaho.di.core.util | |
org.pentaho.di.job |
This package contains the different elements that make up a Job.
|
org.pentaho.di.job.entries.eval | |
org.pentaho.di.job.entries.job | |
org.pentaho.di.job.entries.zipfile | |
org.pentaho.di.job.entry | |
org.pentaho.di.trans |
This package contains the classes needed to define and execute transformations.
|
org.pentaho.di.trans.steps.jobexecutor | |
org.pentaho.di.www | |
org.pentaho.di.www.jaxrs |
Modifier and Type | Method and Description |
---|---|
void |
SubComponentExecutionListener.afterJobExecution(Job job)
This method is called right after a job was executed in a parent job or transformation (Job job-entry, Job Executor
step).
|
void |
SubComponentExecutionAdapter.afterJobExecution(Job job) |
void |
SubComponentExecutionListener.beforeJobExecution(Job job)
This method is called right before a job is to be executed in a parent job or transformation (Job job-entry, Job
Executor step).
|
void |
SubComponentExecutionAdapter.beforeJobExecution(Job job) |
Modifier and Type | Method and Description |
---|---|
org.pentaho.di.core.variables.VariableSpace |
CurrentDirectoryResolver.resolveCurrentDirectory(org.pentaho.di.core.ObjectLocationSpecificationMethod specificationMethod,
org.pentaho.di.core.variables.VariableSpace parentVariables,
Repository repository,
Job job,
String filename) |
Modifier and Type | Field and Description |
---|---|
Job |
JobExecutionExtension.job |
Modifier and Type | Method and Description |
---|---|
static Job |
Job.createJobWithNewClassLoader()
Creates the job with new class loader.
|
Job |
Job.getParentJob()
Gets the parent job.
|
Modifier and Type | Method and Description |
---|---|
void |
JobEntryListener.afterExecution(Job job,
JobEntryCopy jobEntryCopy,
JobEntryInterface jobEntryInterface,
org.pentaho.di.core.Result result) |
void |
JobEntryListener.beforeExecution(Job job,
JobEntryCopy jobEntryCopy,
JobEntryInterface jobEntryInterface) |
void |
DelegationListener.jobDelegationStarted(Job delegatedJob,
JobExecutionConfiguration jobExecutionConfiguration) |
void |
DelegationAdapter.jobDelegationStarted(Job delegatedJob,
JobExecutionConfiguration jobExecutionConfiguration) |
void |
JobListener.jobFinished(Job job) |
void |
JobAdapter.jobFinished(Job job) |
void |
JobListener.jobStarted(Job job) |
void |
JobAdapter.jobStarted(Job job) |
void |
Job.setParentJob(Job parentJob)
Sets the parent job.
|
Constructor and Description |
---|
JobExecutionExtension(Job job,
org.pentaho.di.core.Result result,
JobEntryCopy jobEntryCopy,
boolean executeEntry) |
Modifier and Type | Method and Description |
---|---|
boolean |
JobEntryEval.evaluate(org.pentaho.di.core.Result result,
Job parentJob,
org.pentaho.di.core.Result prev_result)
Evaluate the result of the execution of previous job entry.
|
Modifier and Type | Method and Description |
---|---|
Job |
JobEntryJob.getJob() |
Job |
JobEntryJobRunner.getJob() |
Modifier and Type | Method and Description |
---|---|
void |
JobEntryJobRunner.setJob(Job job) |
Constructor and Description |
---|
JobEntryJobRunner(Job job,
org.pentaho.di.core.Result result,
int entryNr,
org.pentaho.di.core.logging.LogChannelInterface log) |
Modifier and Type | Method and Description |
---|---|
boolean |
JobEntryZipFile.processRowFile(Job parentJob,
org.pentaho.di.core.Result result,
String realZipfilename,
String realWildcard,
String realWildcardExclude,
String realSourceDirectoryOrFile,
String realMovetodirectory,
boolean createparentfolder) |
Modifier and Type | Method and Description |
---|---|
Job |
JobEntryInterface.getParentJob()
Gets the parent job.
|
Job |
JobEntryBase.getParentJob()
Gets the parent job.
|
Modifier and Type | Method and Description |
---|---|
void |
JobEntryInterface.setParentJob(Job job)
Sets the parent job.
|
void |
JobEntryBase.setParentJob(Job parentJob)
Sets the parent job.
|
Modifier and Type | Method and Description |
---|---|
Job |
Trans.getParentJob()
Gets the parent job, or null if there is no parent.
|
Modifier and Type | Method and Description |
---|---|
Map<String,Job> |
Trans.getActiveSubjobs()
Gets the active sub-jobs.
|
Modifier and Type | Method and Description |
---|---|
static org.pentaho.di.core.Result |
Trans.getClusteredTransformationResult(org.pentaho.di.core.logging.LogChannelInterface log,
TransSplitter transSplitter,
Job parentJob)
Gets the clustered transformation result.
|
static org.pentaho.di.core.Result |
Trans.getClusteredTransformationResult(org.pentaho.di.core.logging.LogChannelInterface log,
TransSplitter transSplitter,
Job parentJob,
boolean loggingRemoteWork)
Gets the clustered transformation result.
|
static long |
Trans.monitorClusteredTransformation(org.pentaho.di.core.logging.LogChannelInterface log,
TransSplitter transSplitter,
Job parentJob)
Monitors a clustered transformation every second, after all the transformations in a cluster schema are running.
|
static long |
Trans.monitorClusteredTransformation(org.pentaho.di.core.logging.LogChannelInterface log,
TransSplitter transSplitter,
Job parentJob,
int sleepTimeSeconds)
Monitors a clustered transformation every second, after all the transformations in a cluster schema are running.
|
void |
Trans.setParentJob(Job parentJob)
Sets the parent job for the transformation.
|
Modifier and Type | Field and Description |
---|---|
Job |
JobExecutorData.executorJob |
Modifier and Type | Method and Description |
---|---|
Job |
JobExecutor.getExecutorJob() |
Modifier and Type | Method and Description |
---|---|
Job |
JobMap.findJob(String id)
Find a job using the container/carte object ID.
|
Job |
JobMap.getJob(CarteObjectEntry entry) |
Job |
JobMap.getJob(String jobName)
Find the first job in the list that comes to mind!
|
Modifier and Type | Method and Description |
---|---|
void |
JobMap.addJob(String jobName,
String carteObjectId,
Job job,
JobConfiguration jobConfiguration) |
void |
CarteDelegationHandler.jobDelegationStarted(Job delegatedJob,
JobExecutionConfiguration jobExecutionConfiguration) |
void |
JobMap.registerJob(Job job,
JobConfiguration jobConfiguration) |
void |
JobMap.replaceJob(CarteObjectEntry entry,
Job job,
JobConfiguration jobConfiguration) |
Modifier and Type | Method and Description |
---|---|
static Job |
CarteResource.getJob(String id) |