|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.job.entry.JobEntryBase org.pentaho.di.job.entries.job.JobEntryJob
public class JobEntryJob
Recursive definition of a Job. This step means that an entire Job has to be executed. It can be the same Job, but just make sure that you don't get an endless loop. Provide an escape routine using JobEval.
Field Summary | |
---|---|
boolean |
addDate
|
boolean |
addTime
|
boolean |
argFromPrevious
|
String[] |
arguments
|
boolean |
createParentFolder
|
static LogLevel |
DEFAULT_LOG_LEVEL
|
boolean |
execPerRow
|
boolean |
followingAbortRemotely
|
String |
logext
|
String |
logfile
|
LogLevel |
logFileLevel
|
boolean |
parallel
|
String[] |
parameterFieldNames
|
String[] |
parameters
|
String[] |
parameterValues
|
boolean |
paramsFromPrevious
|
boolean |
passingAllParameters
|
boolean |
setAppendLogfile
|
boolean |
setLogfile
|
boolean |
waitingToFinish
|
Constructor Summary | |
---|---|
JobEntryJob()
|
|
JobEntryJob(String name)
|
Method Summary | |
---|---|
void |
check(List<CheckResultInterface> remarks,
JobMeta jobMeta)
Support for overrides not having to put in a check method. |
void |
clear()
Clears all variable values |
Object |
clone()
This method is called when a job entry is duplicated in Spoon. |
boolean |
evaluates()
This method must return true if the job entry supports the true/false outgoing hops. |
Result |
execute(Result result,
int nr)
Execute the job entry. |
String |
exportResources(VariableSpace space,
Map<String,ResourceDefinition> definitions,
ResourceNamingInterface namingInterface,
Repository repository)
We're going to load the transformation meta data referenced here. |
String |
getDirectory()
|
String |
getFilename()
Gets the filename of the job entry. |
String |
getFileName()
Deprecated. use getFilename() instead. |
Job |
getJob()
|
JobMeta |
getJobMeta(Repository rep,
VariableSpace space)
|
String |
getJobName()
|
ObjectId |
getJobObjectId()
|
String |
getLogFilename()
|
String |
getRealFilename()
Gets the real filename of the job entry, by substituting any environment variables present in the filename. |
String |
getRemoteSlaveServerName()
|
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Gets a list of all the resource dependencies that the step is depending on. |
ObjectLocationSpecificationMethod |
getSpecificationMethod()
|
List<SQLStatement> |
getSQLStatements(Repository repository)
Gets the SQL statements needed by this job entry to execute successfully. |
List<SQLStatement> |
getSQLStatements(Repository repository,
VariableSpace space)
Gets the SQL statements needed by this job entry to execute successfully, given a set of variables. |
String |
getXML()
This method is called by PDI whenever a job entry needs to serialize its settings to XML. |
boolean |
hasRepositoryReferences()
Checks whether the job entry has repository references. |
boolean |
isExecPerRow()
|
boolean |
isFollowingAbortRemotely()
|
boolean |
isPassingAllParameters()
|
boolean |
isPassingExport()
|
boolean |
isUnconditional()
This method must return true if the job entry supports the unconditional outgoing hop. |
boolean |
isWaitingToFinish()
|
void |
loadRep(Repository rep,
ObjectId id_jobentry,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers)
Load the jobentry from repository |
void |
loadXML(Node entrynode,
List<DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
This method is called by PDI whenever a job entry needs to read its settings from XML. |
void |
lookupRepositoryReferences(Repository repository)
Look up the references after import |
static void |
main(String[] args)
|
void |
saveRep(Repository rep,
ObjectId id_job)
This method is called by PDI whenever a job entry needs to save its settings to a PDI repository. |
void |
setDirectory(String directory)
|
void |
setExecPerRow(boolean runEveryResultRow)
|
void |
setFileName(String n)
|
void |
setFollowingAbortRemotely(boolean followingAbortRemotely)
|
void |
setJobName(String jobname)
|
void |
setJobObjectId(ObjectId jobObjectId)
|
void |
setPassingAllParameters(boolean passingAllParameters)
|
void |
setPassingExport(boolean passingExport)
|
void |
setRemoteSlaveServerName(String remoteSlaveServerName)
|
void |
setSpecificationMethod(ObjectLocationSpecificationMethod specificationMethod)
|
void |
setWaitingToFinish(boolean waitingToFinish)
|
Methods inherited from class java.lang.Object |
---|
getClass, hashCode, notify, notifyAll, wait, wait, wait |
Methods inherited from interface org.pentaho.di.job.entry.JobEntryInterface |
---|
getDescription, getDialogClassName, getLogChannel, getName, getObjectId, getParentJob, getPluginId, getTypeId, getUsedDatabaseConnections, hasChanged, isDummy, isEvaluation, isJob, isMail, isShell, isSpecial, isStart, isTransformation, resetErrorsBeforeExecution, setChanged, setChanged, setDescription, setName, setObjectId, setParentJob, setPluginId, setRepository |
Field Detail |
---|
public String[] arguments
public boolean argFromPrevious
public boolean paramsFromPrevious
public boolean execPerRow
public String[] parameters
public String[] parameterFieldNames
public String[] parameterValues
public boolean setLogfile
public String logfile
public String logext
public boolean addDate
public boolean addTime
public LogLevel logFileLevel
public boolean parallel
public boolean setAppendLogfile
public boolean createParentFolder
public boolean waitingToFinish
public boolean followingAbortRemotely
public boolean passingAllParameters
public static final LogLevel DEFAULT_LOG_LEVEL
Constructor Detail |
---|
public JobEntryJob(String name)
public JobEntryJob()
Method Detail |
---|
public Object clone()
JobEntryBase
clone
in interface JobEntryInterface
clone
in class JobEntryBase
public void setFileName(String n)
public String getFileName()
public String getFilename()
JobEntryBase
getFilename
in interface LoggingObjectInterface
getFilename
in interface JobEntryInterface
getFilename
in class JobEntryBase
LoggingObjectInterface.getFilename()
public String getRealFilename()
JobEntryBase
getRealFilename
in interface JobEntryInterface
getRealFilename
in class JobEntryBase
public void setJobName(String jobname)
public String getJobName()
public String getDirectory()
public void setDirectory(String directory)
public boolean isPassingExport()
public void setPassingExport(boolean passingExport)
public String getLogFilename()
public String getXML()
JobEntryBase
getXML
in interface JobEntryInterface
getXML
in class JobEntryBase
public void loadXML(Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers, Repository rep) throws KettleXMLException
JobEntryInterface
loadXML
in interface JobEntryInterface
entrynode
- the top-level XML nodedatabases
- the list of databasesslaveServers
- the list of slave serversrep
- the repository object
KettleXMLException
- if any errors occur during the loading of the XMLpublic void loadRep(Repository rep, ObjectId id_jobentry, List<DatabaseMeta> databases, List<SlaveServer> slaveServers) throws KettleException
loadRep
in interface JobEntryInterface
loadRep
in class JobEntryBase
rep
- the repository objectid_jobentry
- the id of the job entrydatabases
- the list of databasesslaveServers
- the list of slave servers
KettleException
- if any errors occur during the loadpublic void saveRep(Repository rep, ObjectId id_job) throws KettleException
JobEntryBase
saveRep
in interface JobEntryInterface
saveRep
in class JobEntryBase
rep
- the repository objectid_job
- the id_job
KettleException
- if any errors occur during the savepublic Result execute(Result result, int nr) throws KettleException
JobEntryInterface
execute
in interface JobEntryInterface
result
- the previous resultnr
- the number of rows
KettleException
- if any Kettle exceptions occurpublic void clear()
JobEntryBase
clear
in interface JobEntryInterface
clear
in class JobEntryBase
public boolean evaluates()
JobEntryBase
evaluates
in interface JobEntryInterface
evaluates
in class JobEntryBase
public boolean isUnconditional()
JobEntryBase
isUnconditional
in interface JobEntryInterface
isUnconditional
in class JobEntryBase
public List<SQLStatement> getSQLStatements(Repository repository) throws KettleException
JobEntryBase
getSQLStatements
in interface JobEntryInterface
getSQLStatements
in class JobEntryBase
repository
- the repository
KettleException
- if any errors occur during the generation of SQL statementspublic List<SQLStatement> getSQLStatements(Repository repository, VariableSpace space) throws KettleException
JobEntryBase
getSQLStatements
in interface JobEntryInterface
getSQLStatements
in class JobEntryBase
repository
- the repository objectspace
- a variable space object containing variable bindings
KettleException
- if any errors occur during the generation of SQL statementspublic JobMeta getJobMeta(Repository rep, VariableSpace space) throws KettleException
KettleException
public boolean isExecPerRow()
public void setExecPerRow(boolean runEveryResultRow)
runEveryResultRow
- The runEveryResultRow to set.public List<ResourceReference> getResourceDependencies(JobMeta jobMeta)
JobEntryBase
getResourceDependencies
in interface JobEntryInterface
getResourceDependencies
in class JobEntryBase
ResourceReference
public String exportResources(VariableSpace space, Map<String,ResourceDefinition> definitions, ResourceNamingInterface namingInterface, Repository repository) throws KettleException
exportResources
in interface JobEntryInterface
exportResources
in class JobEntryBase
space
- The variable space to resolve (environment) variables with.definitions
- The map containing the filenames and contentnamingInterface
- The resource naming interface allows the object to be named appropriatelyrepository
- The repository to load resources from
KettleException
- in case something goes wrong during the exportpublic void check(List<CheckResultInterface> remarks, JobMeta jobMeta)
JobEntryBase
check
in interface JobEntryInterface
check
in class JobEntryBase
remarks
- CheckResults from checking the job entryjobMeta
- JobMeta information letting threading back to the JobMeta possiblepublic static void main(String[] args)
public String getRemoteSlaveServerName()
public void setRemoteSlaveServerName(String remoteSlaveServerName)
remoteSlaveServerName
- the remoteSlaveServer to setpublic boolean isWaitingToFinish()
public void setWaitingToFinish(boolean waitingToFinish)
waitingToFinish
- the waitingToFinish to setpublic boolean isFollowingAbortRemotely()
public void setFollowingAbortRemotely(boolean followingAbortRemotely)
followingAbortRemotely
- the followingAbortRemotely to setpublic boolean isPassingAllParameters()
public void setPassingAllParameters(boolean passingAllParameters)
passingAllParameters
- the passingAllParameters to setpublic Job getJob()
public ObjectId getJobObjectId()
public void setJobObjectId(ObjectId jobObjectId)
jobObjectId
- the jobObjectId to setpublic ObjectLocationSpecificationMethod getSpecificationMethod()
public void setSpecificationMethod(ObjectLocationSpecificationMethod specificationMethod)
specificationMethod
- the specificationMethod to setpublic boolean hasRepositoryReferences()
JobEntryBase
hasRepositoryReferences
in interface JobEntryInterface
hasRepositoryReferences
in class JobEntryBase
public void lookupRepositoryReferences(Repository repository) throws KettleException
lookupRepositoryReferences
in interface JobEntryInterface
lookupRepositoryReferences
in class JobEntryBase
repository
- the repository to reference.
KettleException
- if any errors occur during the lookup
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |