public class JobEntryTrans extends JobEntryBase implements Cloneable, JobEntryInterface, HasRepositoryDirectories, JobEntryRunConfigurableInterface
| Modifier and Type | Field and Description |
|---|---|
boolean |
addDate |
boolean |
addTime |
boolean |
argFromPrevious |
String[] |
arguments |
boolean |
clearResultFiles |
boolean |
clearResultRows |
boolean |
createParentFolder |
boolean |
execPerRow |
boolean |
followingAbortRemotely |
static int |
IS_PENTAHO |
String |
logext |
String |
logfile |
LogLevel |
logFileLevel |
String[] |
parameterFieldNames |
String[] |
parameters |
String[] |
parameterValues |
boolean |
paramsFromPrevious |
boolean |
setAppendLogfile |
boolean |
setLogfile |
boolean |
waitingToFinish |
attributesMap, containerObjectId, entryStepSetVariablesMap, extensionDataMap, log, metaStore, parentJob, parentJobMeta, rep, variables| Constructor and Description |
|---|
JobEntryTrans() |
JobEntryTrans(String name) |
| Modifier and Type | Method and Description |
|---|---|
void |
check(List<CheckResultInterface> remarks,
JobMeta jobMeta,
VariableSpace space,
Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore)
Allows JobEntry objects to check themselves for consistency
|
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,
org.pentaho.metastore.api.IMetaStore metaStore)
We're going to load the transformation meta data referenced here.
|
String[] |
getDirectories()
If step has reference(s) to another transformation(s)/job(s) returns an array of repository directories.
|
String |
getDirectory() |
String |
getDirectoryPath() |
String |
getFilename()
Gets the filename of the job entry.
|
String |
getFileName()
Deprecated.
use getFilename() instead
|
protected String |
getLogfile() |
String |
getLogFilename() |
String |
getRealFilename()
Gets the real filename of the job entry, by substituting any environment variables present in the filename.
|
String[] |
getReferencedObjectDescriptions() |
String |
getRemoteSlaveServerName() |
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Gets a list of all the resource dependencies that the step is depending on.
|
String |
getRunConfiguration() |
ObjectLocationSpecificationMethod |
getSpecificationMethod() |
ObjectLocationSpecificationMethod[] |
getSpecificationMethods()
If step has reference(s) to another transformation(s)/job(s) returns an array of specification method(s)
defining the type of an access to a referenced file.
|
List<SQLStatement> |
getSQLStatements(Repository repository,
org.pentaho.metastore.api.IMetaStore metaStore,
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,
org.pentaho.metastore.api.IMetaStore metaStore,
VariableSpace space) |
TransMeta |
getTransMeta(Repository rep,
VariableSpace space)
Deprecated.
|
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 |
isLoggingRemoteWork() |
boolean |
isPassingAllParameters() |
boolean[] |
isReferencedObjectEnabled() |
boolean |
isUnconditional()
This method must return true if the job entry supports the unconditional outgoing hop.
|
boolean |
isWaitingToFinish() |
Object |
loadReferencedObject(int index,
Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
VariableSpace space)
Load the referenced object
|
void |
loadRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
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,
org.pentaho.metastore.api.IMetaStore metaStore)
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 |
prepareFieldNamesParameters(String[] parameters,
String[] parameterFieldNames,
String[] parameterValues,
NamedParams namedParam,
JobEntryTrans jobEntryTrans) |
void |
saveRep(Repository rep,
org.pentaho.metastore.api.IMetaStore metaStore,
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 |
setDirectories(String[] directories)
If step has reference(s) to another transformation(s)/job(s) sets updated repository directories from
incoming String array.
|
void |
setDirectory(String directory) |
void |
setDirectoryPath(String directoryPath) |
void |
setFileName(String n) |
void |
setFollowingAbortRemotely(boolean followingAbortRemotely) |
void |
setLoggingRemoteWork(boolean loggingRemoteWork) |
void |
setParentJobMeta(JobMeta parentJobMeta)
At save and run time, the system will attempt to set the jobMeta so that it can be accessed by the jobEntries
if necessary.
|
void |
setPassingAllParameters(boolean passingAllParameters) |
void |
setRemoteSlaveServerName(String remoteSlaveServerName) |
void |
setRunConfiguration(String runConfiguration) |
void |
setSpecificationMethod(ObjectLocationSpecificationMethod specificationMethod) |
void |
setTransname(String transname) |
void |
setTransObjectId(ObjectId transObjectId) |
void |
setWaitingToFinish(boolean waitingToFinish) |
check, copyVariablesFrom, environmentSubstitute, environmentSubstitute, equals, exportResources, fieldSubstitute, getAttribute, getAttributes, getAttributesMap, getBooleanValueOfVariable, getContainerObjectId, getDescription, getDialogClassName, getEntryStepSetVariable, getEntryStepSetVariablesMap, getExtensionDataMap, getHolderType, getLogChannel, getLogChannelId, getLogLevel, getMetaStore, getName, getObjectCopy, getObjectId, getObjectName, getObjectRevision, getObjectType, getParent, getParentJob, getParentJobMeta, getParentVariableSpace, getPluginId, getRegistrationDate, getRepository, getRepositoryDirectory, getSQLStatements, getSQLStatements, getTypeDesc, getTypeId, getUsedDatabaseConnections, getVariable, getVariable, getVariables, hasChanged, hashCode, initializeVariablesFrom, injectVariables, isBasic, isDebug, isDetailed, isDummy, isEvaluation, isForcingSeparateLogging, isFTP, isGatheringMetrics, isHTTP, isJob, isMail, isRowlevel, isSFTP, isShell, isSpecial, isStart, isTransformation, listVariables, loadReferencedObject, loadRep, loadXML, loadXML, logBasic, logBasic, logDebug, logDebug, logDetailed, logDetailed, logError, logError, logError, logMinimal, logMinimal, logRowlevel, logRowlevel, parseRepositoryObjects, resetErrorsBeforeExecution, saveRep, setAttribute, setAttributes, setAttributesMap, setChanged, setChanged, setContainerObjectId, setDescription, setEntryStepSetVariable, setForcingSeparateLogging, setGatheringMetrics, setID, setLogLevel, setMetaStore, setName, setObjectId, setParentJob, setParentVariableSpace, setPluginId, setRepository, setTypeId, setVariable, shareVariablesWith, toStringfinalize, getClass, notify, notifyAll, wait, wait, waitcheck, exportResources, getDescription, getDialogClassName, getLogChannel, getName, getObjectId, getParentJob, getParentJobMeta, getPluginId, getSQLStatements, getSQLStatements, getTypeId, getUsedDatabaseConnections, hasChanged, isDummy, isEvaluation, isJob, isMail, isShell, isSpecial, isStart, isTransformation, loadReferencedObject, loadRep, loadXML, resetErrorsBeforeExecution, saveRep, setChanged, setChanged, setDescription, setMetaStore, setName, setObjectId, setParentJob, setPluginId, setRepositorysetChangedpublic static final int IS_PENTAHO
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
public JobEntryTrans(String name)
public JobEntryTrans()
public Object clone()
JobEntryBaseclone in interface JobEntryInterfaceclone in class JobEntryBasepublic void setFileName(String n)
@Deprecated public String getFileName()
public String getFilename()
JobEntryBasegetFilename in interface LoggingObjectInterfacegetFilename in interface JobEntryInterfacegetFilename in class JobEntryBaseLoggingObjectInterface.getFilename()public String getRealFilename()
JobEntryBasegetRealFilename in interface JobEntryInterfacegetRealFilename in class JobEntryBasepublic void setTransname(String transname)
public String getTransname()
public String getDirectory()
public void setDirectory(String directory)
public String[] getDirectories()
HasRepositoryDirectoriesgetDirectories in interface HasRepositoryDirectoriespublic void setDirectories(String[] directories)
HasRepositoryDirectoriessetDirectories in interface HasRepositoryDirectoriesdirectories - Array of updated rep directories to setpublic String getLogFilename()
public String getXML()
JobEntryBasegetXML in interface JobEntryInterfacegetXML in class JobEntryBasepublic void loadXML(Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers, Repository rep, org.pentaho.metastore.api.IMetaStore metaStore) throws KettleXMLException
JobEntryInterfaceloadXML in interface JobEntryInterfaceloadXML in class JobEntryBaseentrynode - the top-level XML nodedatabases - the list of databasesslaveServers - the list of slave serversrep - the repository objectmetaStore - The metaStore to optionally load from.KettleXMLException - if any errors occur during the loading of the XMLpublic void loadRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, ObjectId id_jobentry, List<DatabaseMeta> databases, List<SlaveServer> slaveServers) throws KettleException
JobEntryInterfaceloadRep in interface JobEntryInterfaceloadRep in class JobEntryBaserep - the repository objectmetaStore - the MetaStore to useid_jobentry - the id of the job entrydatabases - the list of databasesslaveServers - the list of slave serversKettleException - if any errors occur during the loadpublic void saveRep(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, ObjectId id_job) throws KettleException
JobEntryInterfacesaveRep in interface JobEntryInterfacesaveRep in class JobEntryBaserep - the repositorymetaStore - the MetaStore to useid_job - the id_jobKettleException - if any errors occur during the savepublic void clear()
JobEntryBaseclear in interface JobEntryInterfaceclear in class JobEntryBasepublic Result execute(Result result, int nr) throws KettleException
execute in interface JobEntryInterfaceresult - The result of the previous executionnr - the job entry numberKettleException - if any Kettle exceptions occur@Deprecated public TransMeta getTransMeta(Repository rep, VariableSpace space) throws KettleException
getTransMeta(Repository, IMetaStore, VariableSpace)rep - space - KettleExceptionpublic TransMeta getTransMeta(Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, VariableSpace space) throws KettleException
KettleExceptionpublic boolean evaluates()
JobEntryBaseevaluates in interface JobEntryInterfaceevaluates in class JobEntryBasepublic boolean isUnconditional()
JobEntryBaseisUnconditional in interface JobEntryInterfaceisUnconditional in class JobEntryBasepublic List<SQLStatement> getSQLStatements(Repository repository, org.pentaho.metastore.api.IMetaStore metaStore, VariableSpace space) throws KettleException
JobEntryBasegetSQLStatements in interface JobEntryInterfacegetSQLStatements in class JobEntryBaserepository - the repository objectmetaStore - the MetaStore to usespace - a variable space object containing variable bindingsKettleException - 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, VariableSpace space, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore)
JobEntryBasecheck in interface JobEntryInterfacecheck in class JobEntryBaseremarks - List of CheckResult objects indicating consistency statusjobMeta - the metadata object for the job entryspace - the variable space to resolve string expressions with variables withrepository - the repository to load Kettle objects frommetaStore - the MetaStore to load common elements frompublic List<ResourceReference> getResourceDependencies(JobMeta jobMeta)
JobEntryBasegetResourceDependencies in interface JobEntryInterfacegetResourceDependencies in class JobEntryBaseResourceReferencepublic String exportResources(VariableSpace space, Map<String,ResourceDefinition> definitions, ResourceNamingInterface namingInterface, Repository repository, org.pentaho.metastore.api.IMetaStore metaStore) throws KettleException
exportResources in interface JobEntryInterfaceexportResources in class JobEntryBasespace - 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 frommetaStore - the metaStore to load external metadata fromKettleException - in case something goes wrong during the exportprotected String getLogfile()
public String getRemoteSlaveServerName()
public void setRemoteSlaveServerName(String remoteSlaveServerName)
setRemoteSlaveServerName in interface JobEntryRunConfigurableInterfaceremoteSlaveServerName - 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 isLoggingRemoteWork()
public void setLoggingRemoteWork(boolean loggingRemoteWork)
setLoggingRemoteWork in interface JobEntryRunConfigurableInterfacepublic boolean isPassingAllParameters()
public void setPassingAllParameters(boolean passingAllParameters)
passingAllParameters - the passingAllParameters to setpublic String getRunConfiguration()
getRunConfiguration in interface JobEntryRunConfigurableInterfacepublic void setRunConfiguration(String runConfiguration)
setRunConfiguration in interface JobEntryRunConfigurableInterfacepublic Trans getTrans()
public ObjectId getTransObjectId()
public void setTransObjectId(ObjectId transObjectId)
transObjectId - the transObjectId to setpublic ObjectLocationSpecificationMethod getSpecificationMethod()
public ObjectLocationSpecificationMethod[] getSpecificationMethods()
HasRepositoryDirectoriesgetSpecificationMethods in interface HasRepositoryDirectoriespublic void setSpecificationMethod(ObjectLocationSpecificationMethod specificationMethod)
specificationMethod - the specificationMethod to setpublic boolean hasRepositoryReferences()
JobEntryBasehasRepositoryReferences in interface JobEntryInterfacehasRepositoryReferences in class JobEntryBasepublic void lookupRepositoryReferences(Repository repository) throws KettleException
lookupRepositoryReferences in interface JobEntryInterfacelookupRepositoryReferences in class JobEntryBaserepository - the repository to reference.KettleException - if any errors occur during the lookuppublic String[] getReferencedObjectDescriptions()
getReferencedObjectDescriptions in interface JobEntryInterfacegetReferencedObjectDescriptions in class JobEntryBasepublic boolean[] isReferencedObjectEnabled()
isReferencedObjectEnabled in interface JobEntryInterfaceisReferencedObjectEnabled in class JobEntryBasepublic Object loadReferencedObject(int index, Repository rep, org.pentaho.metastore.api.IMetaStore metaStore, VariableSpace space) throws KettleException
loadReferencedObject in interface JobEntryInterfaceloadReferencedObject in class JobEntryBaseindex - the referenced object index to load (in case there are multiple references)rep - the repositorymetaStore - metaStorespace - the variable space to useKettleExceptionpublic void setParentJobMeta(JobMeta parentJobMeta)
JobEntryBasesetParentJobMeta in interface JobEntryInterfacesetParentJobMeta in class JobEntryBaseparentJobMeta - the JobMeta to which this JobEntryInterface belongspublic void prepareFieldNamesParameters(String[] parameters, String[] parameterFieldNames, String[] parameterValues, NamedParams namedParam, JobEntryTrans jobEntryTrans) throws UnknownParamException
UnknownParamExceptionCopyright © 2018 Hitachi Vantara. All rights reserved.