|
||||||||||
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.trans.JobEntryTrans
public class JobEntryTrans
This is the job entry that defines a transformation to be run.
Field Summary | |
---|---|
boolean |
addDate
|
boolean |
addTime
|
boolean |
argFromPrevious
|
String[] |
arguments
|
boolean |
clearResultFiles
|
boolean |
clearResultRows
|
boolean |
createParentFolder
|
boolean |
execPerRow
|
boolean |
followingAbortRemotely
|
String |
logext
|
String |
logfile
|
LogLevel |
logFileLevel
|
String[] |
parameterFieldNames
|
String[] |
parameters
|
String[] |
parameterValues
|
boolean |
paramsFromPrevious
|
boolean |
setAppendLogfile
|
boolean |
setLogfile
|
boolean |
waitingToFinish
|
Constructor Summary | |
---|---|
JobEntryTrans()
|
|
JobEntryTrans(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 this job entry and return the result. |
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 |
getDirectoryPath()
|
String |
getFilename()
Gets the filename of the job entry. |
String |
getFileName()
Deprecated. use getFilename() instead |
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. |
Trans |
getTrans()
|
TransMeta |
getTransMeta(Repository rep,
VariableSpace space)
|
String |
getTransname()
|
ObjectId |
getTransObjectId()
|
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 |
isClustering()
|
boolean |
isFollowingAbortRemotely()
|
boolean |
isPassingAllParameters()
|
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)
This method is called by PDI whenever a job entry needs to read its configuration from a PDI 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 |
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 |
setClustering(boolean clustering)
|
void |
setDirectory(String directory)
|
void |
setDirectoryPath(String directoryPath)
|
void |
setFileName(String n)
|
void |
setFollowingAbortRemotely(boolean followingAbortRemotely)
|
void |
setPassingAllParameters(boolean passingAllParameters)
|
void |
setRemoteSlaveServerName(String remoteSlaveServerName)
|
void |
setSpecificationMethod(ObjectLocationSpecificationMethod specificationMethod)
|
void |
setTransname(String transname)
|
void |
setTransObjectId(ObjectId transObjectId)
|
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 clearResultRows
public boolean clearResultFiles
public boolean createParentFolder
public boolean setLogfile
public boolean setAppendLogfile
public String logfile
public String logext
public boolean addDate
public boolean addTime
public LogLevel logFileLevel
public boolean waitingToFinish
public boolean followingAbortRemotely
Constructor Detail |
---|
public JobEntryTrans(String name)
public JobEntryTrans()
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 setTransname(String transname)
public String getTransname()
public String getDirectory()
public void setDirectory(String directory)
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
JobEntryBase
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 void clear()
JobEntryBase
clear
in interface JobEntryInterface
clear
in class JobEntryBase
public Result execute(Result result, int nr) throws KettleException
execute
in interface JobEntryInterface
result
- The result of the previous executionnr
- the job entry numberrep
- the repository connection to useparentJob
- the parent job
KettleException
- if any Kettle exceptions occurpublic TransMeta getTransMeta(Repository rep, VariableSpace space) throws KettleException
KettleException
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, 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 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 String getDirectoryPath()
public void setDirectoryPath(String directoryPath)
directoryPath
- The directoryPath to set.public boolean isClustering()
public void setClustering(boolean clustering)
clustering
- the clustering to setpublic 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 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 String getRemoteSlaveServerName()
public void setRemoteSlaveServerName(String remoteSlaveServerName)
remoteSlaveServerName
- the remote slave server name 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 Trans getTrans()
public ObjectId getTransObjectId()
public void setTransObjectId(ObjectId transObjectId)
transObjectId
- the transObjectId 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 |