|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectjava.lang.Thread
org.pentaho.di.job.Job
public class Job
This class executes a JobInfo object.
Nested Class Summary |
---|
Nested classes/interfaces inherited from class java.lang.Thread |
---|
Thread.State, Thread.UncaughtExceptionHandler |
Field Summary | |
---|---|
static String |
CONFIGURATION_IN_EXPORT_FILENAME
|
Fields inherited from class java.lang.Thread |
---|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY |
Constructor Summary | |
---|---|
Job()
|
|
Job(org.pentaho.di.core.logging.LogWriter lw,
Repository rep,
JobMeta ti)
|
|
Job(org.pentaho.di.core.logging.LogWriter lw,
StepLoader steploader,
Repository rep,
JobMeta ti)
|
|
Job(org.pentaho.di.core.logging.LogWriter lw,
String name,
String file,
String[] args)
|
Method Summary | |
---|---|
void |
activateParameters()
|
void |
addErrors(int nrToAdd)
Add a number of errors to the total number of erros that occured during execution. |
void |
addJobListener(JobListener jobListener)
Add a job listener to the job |
void |
addParameterDefinition(String key,
String defValue,
String description)
|
boolean |
beginProcessing()
|
void |
clearParameters()
|
void |
copyParametersFrom(org.pentaho.di.core.parameters.NamedParams params)
|
void |
copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
|
static Job |
createJobWithNewClassLoader()
|
boolean |
endProcessing(String status,
org.pentaho.di.core.Result res)
|
String |
environmentSubstitute(String aString)
|
String[] |
environmentSubstitute(String[] aString)
|
void |
eraseParameters()
|
org.pentaho.di.core.Result |
execute()
Execute a job without previous results. |
org.pentaho.di.core.Result |
execute(int nr,
org.pentaho.di.core.Result result)
Execute a job with previous results passed in. Execute called by JobEntryJob: don't clear the jobEntryResults. |
long |
getBatchId()
|
boolean |
getBooleanValueOfVariable(String variableName,
boolean defaultValue)
|
Date |
getCurrentDate()
|
Date |
getDepDate()
|
Date |
getEndDate()
|
int |
getErrors()
Get the number of errors that happened in the job. |
List<JobListener> |
getJobListeners()
|
JobMeta |
getJobMeta()
|
String |
getJobname()
|
JobTracker |
getJobTracker()
|
org.pentaho.di.core.logging.LogWriter |
getLog()
|
Date |
getLogDate()
|
String |
getParameterDefault(String key)
|
String |
getParameterDescription(String key)
|
String |
getParameterValue(String key)
|
Job |
getParentJob()
|
org.pentaho.di.core.variables.VariableSpace |
getParentVariableSpace()
|
long |
getPassedBatchId()
|
Repository |
getRep()
|
org.pentaho.di.core.Result |
getResult()
|
SocketRepository |
getSocketRepository()
|
List<org.pentaho.di.core.RowMetaAndData> |
getSourceRows()
|
Date |
getStartDate()
|
String |
getStatus()
|
Thread |
getThread()
|
String |
getVariable(String variableName)
|
String |
getVariable(String variableName,
String defaultValue)
|
void |
init(org.pentaho.di.core.logging.LogWriter lw,
String name,
String file,
String[] args)
|
void |
initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
|
void |
injectVariables(Map<String,String> prop)
|
boolean |
isActive()
|
boolean |
isFinished()
|
boolean |
isInitialized()
|
boolean |
isStopped()
|
String[] |
listParameters()
|
String[] |
listVariables()
|
void |
open(org.pentaho.di.core.logging.LogWriter lw,
Repository rep,
JobMeta ti)
|
void |
open(org.pentaho.di.core.logging.LogWriter lw,
StepLoader steploader,
Repository rep,
JobMeta ti)
|
void |
open(Repository rep,
String fname,
String jobname,
String dirname,
org.pentaho.di.core.gui.OverwritePrompter prompter)
|
void |
resetErrors()
Set the number of occured errors to 0. |
void |
run()
|
static void |
sendToSlaveServer(JobMeta jobMeta,
JobExecutionConfiguration executionConfiguration,
Repository repository)
|
void |
setBatchId(long batchId)
|
void |
setFinished(boolean finished)
|
void |
setInternalKettleVariables(org.pentaho.di.core.variables.VariableSpace var)
|
void |
setJobListeners(List<JobListener> jobListeners)
|
void |
setJobTracker(JobTracker jobTracker)
|
void |
setParameterValue(String key,
String value)
|
void |
setParentJob(Job parentJob)
|
void |
setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
|
void |
setPassedBatchId(long jobBatchId)
|
void |
setRepository(Repository rep)
|
void |
setResult(org.pentaho.di.core.Result result)
|
void |
setSocketRepository(SocketRepository socketRepository)
|
void |
setSourceRows(List<org.pentaho.di.core.RowMetaAndData> sourceRows)
|
void |
setStopped(boolean stopped)
|
void |
setVariable(String variableName,
String variableValue)
|
void |
shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
|
void |
stopAll()
|
void |
waitUntilFinished()
Wait until this job has finished. |
void |
waitUntilFinished(long maxMiliseconds)
Wait until this job has finished. |
Methods inherited from class java.lang.Thread |
---|
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
---|
public static final String CONFIGURATION_IN_EXPORT_FILENAME
Constructor Detail |
---|
public Job(org.pentaho.di.core.logging.LogWriter lw, String name, String file, String[] args)
public Job(org.pentaho.di.core.logging.LogWriter lw, StepLoader steploader, Repository rep, JobMeta ti)
public Job(org.pentaho.di.core.logging.LogWriter lw, Repository rep, JobMeta ti)
public Job()
Method Detail |
---|
public void init(org.pentaho.di.core.logging.LogWriter lw, String name, String file, String[] args)
public void open(org.pentaho.di.core.logging.LogWriter lw, Repository rep, JobMeta ti)
public void open(org.pentaho.di.core.logging.LogWriter lw, StepLoader steploader, Repository rep, JobMeta ti)
public void open(Repository rep, String fname, String jobname, String dirname, org.pentaho.di.core.gui.OverwritePrompter prompter) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public static final Job createJobWithNewClassLoader() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public String getJobname()
public void setRepository(Repository rep)
public void run()
run
in interface Runnable
run
in class Thread
public org.pentaho.di.core.Result execute() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public org.pentaho.di.core.Result execute(int nr, org.pentaho.di.core.Result result) throws org.pentaho.di.core.exception.KettleException
nr
- The job entry numberresult
- the result of the previous execution
org.pentaho.di.core.exception.KettleJobException
org.pentaho.di.core.exception.KettleException
public void waitUntilFinished()
public void waitUntilFinished(long maxMiliseconds)
maxMiliseconds
- the maximum number of ms to waitpublic int getErrors()
public void resetErrors()
public void addErrors(int nrToAdd)
nrToAdd
- nr of errors to add.public boolean beginProcessing() throws org.pentaho.di.core.exception.KettleJobException
org.pentaho.di.core.exception.KettleJobException
public boolean endProcessing(String status, org.pentaho.di.core.Result res) throws org.pentaho.di.core.exception.KettleJobException
org.pentaho.di.core.exception.KettleJobException
public boolean isActive()
public void stopAll()
public void setStopped(boolean stopped)
public boolean isStopped()
public Date getStartDate()
public Date getEndDate()
public Date getCurrentDate()
public Date getDepDate()
public Date getLogDate()
public JobMeta getJobMeta()
public org.pentaho.di.core.logging.LogWriter getLog()
public Repository getRep()
public Thread getThread()
public JobTracker getJobTracker()
public void setJobTracker(JobTracker jobTracker)
jobTracker
- The jobTracker to set.public void setSourceRows(List<org.pentaho.di.core.RowMetaAndData> sourceRows)
public List<org.pentaho.di.core.RowMetaAndData> getSourceRows()
public Job getParentJob()
public void setParentJob(Job parentJob)
parentJob
- The parentJob to set.public org.pentaho.di.core.Result getResult()
public void setResult(org.pentaho.di.core.Result result)
public boolean isInitialized()
public long getBatchId()
public void setBatchId(long batchId)
batchId
- The batchId to set.public long getPassedBatchId()
public void setPassedBatchId(long jobBatchId)
jobBatchId
- the jobBatchId to setpublic void setInternalKettleVariables(org.pentaho.di.core.variables.VariableSpace var)
public void copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
copyVariablesFrom
in interface org.pentaho.di.core.variables.VariableSpace
public String environmentSubstitute(String aString)
environmentSubstitute
in interface org.pentaho.di.core.variables.VariableSpace
public String[] environmentSubstitute(String[] aString)
environmentSubstitute
in interface org.pentaho.di.core.variables.VariableSpace
public org.pentaho.di.core.variables.VariableSpace getParentVariableSpace()
getParentVariableSpace
in interface org.pentaho.di.core.variables.VariableSpace
public void setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
setParentVariableSpace
in interface org.pentaho.di.core.variables.VariableSpace
public String getVariable(String variableName, String defaultValue)
getVariable
in interface org.pentaho.di.core.variables.VariableSpace
public String getVariable(String variableName)
getVariable
in interface org.pentaho.di.core.variables.VariableSpace
public boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
getBooleanValueOfVariable
in interface org.pentaho.di.core.variables.VariableSpace
public void initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
initializeVariablesFrom
in interface org.pentaho.di.core.variables.VariableSpace
public String[] listVariables()
listVariables
in interface org.pentaho.di.core.variables.VariableSpace
public void setVariable(String variableName, String variableValue)
setVariable
in interface org.pentaho.di.core.variables.VariableSpace
public void shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
shareVariablesWith
in interface org.pentaho.di.core.variables.VariableSpace
public void injectVariables(Map<String,String> prop)
injectVariables
in interface org.pentaho.di.core.variables.VariableSpace
public String getStatus()
public static void sendToSlaveServer(JobMeta jobMeta, JobExecutionConfiguration executionConfiguration, Repository repository) throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public List<JobListener> getJobListeners()
public void setJobListeners(List<JobListener> jobListeners)
jobListeners
- the jobListeners to setpublic void addJobListener(JobListener jobListener)
jobListener
- the job listener to addpublic boolean isFinished()
public void setFinished(boolean finished)
finished
- the finished to setpublic void addParameterDefinition(String key, String defValue, String description) throws org.pentaho.di.core.parameters.DuplicateParamException
addParameterDefinition
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.DuplicateParamException
public String getParameterDescription(String key) throws org.pentaho.di.core.parameters.UnknownParamException
getParameterDescription
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.UnknownParamException
public String getParameterDefault(String key) throws org.pentaho.di.core.parameters.UnknownParamException
getParameterDefault
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.UnknownParamException
public String getParameterValue(String key) throws org.pentaho.di.core.parameters.UnknownParamException
getParameterValue
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.UnknownParamException
public String[] listParameters()
listParameters
in interface org.pentaho.di.core.parameters.NamedParams
public void setParameterValue(String key, String value) throws org.pentaho.di.core.parameters.UnknownParamException
setParameterValue
in interface org.pentaho.di.core.parameters.NamedParams
org.pentaho.di.core.parameters.UnknownParamException
public void eraseParameters()
eraseParameters
in interface org.pentaho.di.core.parameters.NamedParams
public void clearParameters()
clearParameters
in interface org.pentaho.di.core.parameters.NamedParams
public void activateParameters()
activateParameters
in interface org.pentaho.di.core.parameters.NamedParams
public void copyParametersFrom(org.pentaho.di.core.parameters.NamedParams params)
copyParametersFrom
in interface org.pentaho.di.core.parameters.NamedParams
public void setSocketRepository(SocketRepository socketRepository)
public SocketRepository getSocketRepository()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |