org.pentaho.di.job.entries.copymoveresultfilenames
Class JobEntryCopyMoveResultFilenames

java.lang.Object
  org.pentaho.di.job.entry.JobEntryBase
      org.pentaho.di.job.entries.copymoveresultfilenames.JobEntryCopyMoveResultFilenames

All Implemented Interfaces:

Cloneable, CheckResultSourceInterface, LoggingObjectInterface, VariableSpace, JobEntryInterface, ResourceHolderInterface

public class JobEntryCopyMoveResultFilenames
extends JobEntryBase
implements Cloneable, JobEntryInterface

This defines a 'copymoveresultfilenames' job entry. Its main use would be to copy or move files in the result filenames to a destination folder. that can be used to control the flow in ETL cycles.

Since:

25-02-2008

Author:

Samatar

Field Summary

String	SUCCESS_IF_AT_LEAST_X_FILES_UN_ZIPPED
String	SUCCESS_IF_ERRORS_LESS
String	SUCCESS_IF_NO_ERRORS

Constructor Summary

JobEntryCopyMoveResultFilenames()

JobEntryCopyMoveResultFilenames(String n)

Method Summary

void	check(List<CheckResultInterface> remarks, JobMeta jobMeta) Support for overrides not having to put in a check method
Object	clone()
boolean	evaluates() check whether or not this job entry evaluates.
Result	execute(Result previousResult, int nr)
String	getAction()
String	getDateTimeFormat()
String	getDestinationFolder()
String	getFoldername()
String	getNrErrorsLessThan()
String	getRealWildcard()
String	getSuccessCondition()
String	getWildcard()
String	getWildcardExclude()
String	getXML()
boolean	isAddDate()
boolean	isAddDateBeforeExtension()
boolean	isAddDestinationFilename()
boolean	isAddTime()
boolean	isCreateDestinationFolder()
boolean	isOverwriteFile()
boolean	isRemovedSourceFilename()
boolean	isSpecifyFormat()
boolean	isSpecifyWildcard()
void	loadRep(Repository rep, ObjectId id_jobentry, List<DatabaseMeta> databases, List<SlaveServer> slaveServers)
void	loadXML(Node entrynode, List<DatabaseMeta> databases, List<SlaveServer> slaveServers, Repository rep)
void	saveRep(Repository rep, ObjectId id_job)
void	setAction(String action)
void	setAddDate(boolean adddate)
void	setAddDateBeforeExtension(boolean AddDateBeforeExtension)
void	setAddDestinationFilename(boolean AddDestinationFilename)
void	setAddTime(boolean addtime)
void	setCreateDestinationFolder(boolean CreateDestinationFolder)
void	setDateTimeFormat(String date_time_format)
void	setDestinationFolder(String destinationFolder)
void	setFoldername(String foldername)
void	setNrErrorsLessThan(String nr_errors_less_than)
void	setOverwriteFile(boolean OverwriteFile)
void	setRemovedSourceFilename(boolean RemovedSourceFilename)
void	setSpecifyFormat(boolean SpecifyFormat)
void	setSpecifyWildcard(boolean specifywildcard)
void	setSuccessCondition(String success_condition)
void	setWildcard(String wildcard)
void	setWildcardExclude(String wildcardexclude)

Methods inherited from class org.pentaho.di.job.entry.JobEntryBase

clear, copyVariablesFrom, environmentSubstitute, environmentSubstitute, equals, exportResources, getBooleanValueOfVariable, getContainerObjectId, getDescription, getDialogClassName, getFilename, getHolderType, getLogChannel, getLogChannelId, getLogLevel, getName, getObjectCopy, getObjectId, getObjectName, getObjectRevision, getObjectType, getParent, getParentJob, getParentVariableSpace, getPluginId, getRealFilename, getRegistrationDate, getRepository, getRepositoryDirectory, getResourceDependencies, getSQLStatements, getSQLStatements, getTypeDesc, getTypeId, getUsedDatabaseConnections, getVariable, getVariable, hasChanged, hasRepositoryReferences, initializeVariablesFrom, injectVariables, isBasic, isDebug, isDetailed, isDummy, isEvaluation, isFTP, isHTTP, isJob, isMail, isRowlevel, isSFTP, isShell, isSpecial, isStart, isTransformation, isUnconditional, listVariables, loadXML, logBasic, logBasic, logDebug, logDebug, logDetailed, logDetailed, logError, logError, logError, logMinimal, logMinimal, logRowlevel, logRowlevel, lookupRepositoryReferences, parseRepositoryObjects, resetErrorsBeforeExecution, setChanged, setChanged, setContainerObjectId, setDescription, setID, setLogLevel, setName, setObjectId, setParentJob, setParentVariableSpace, setPluginId, setRepository, setTypeId, setVariable, shareVariablesWith, toString

Methods inherited from class java.lang.Object

getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.pentaho.di.job.entry.JobEntryInterface

clear, exportResources, getDescription, getDialogClassName, getFilename, getLogChannel, getName, getObjectId, getParentJob, getPluginId, getRealFilename, getResourceDependencies, getSQLStatements, getSQLStatements, getTypeId, getUsedDatabaseConnections, hasChanged, hasRepositoryReferences, isDummy, isEvaluation, isJob, isMail, isShell, isSpecial, isStart, isTransformation, isUnconditional, lookupRepositoryReferences, resetErrorsBeforeExecution, setChanged, setChanged, setDescription, setName, setObjectId, setParentJob, setPluginId, setRepository

Field Detail

SUCCESS_IF_AT_LEAST_X_FILES_UN_ZIPPED

public String SUCCESS_IF_AT_LEAST_X_FILES_UN_ZIPPED

SUCCESS_IF_ERRORS_LESS

public String SUCCESS_IF_ERRORS_LESS

SUCCESS_IF_NO_ERRORS

public String SUCCESS_IF_NO_ERRORS

Constructor Detail

JobEntryCopyMoveResultFilenames

public JobEntryCopyMoveResultFilenames(String n)

JobEntryCopyMoveResultFilenames

public JobEntryCopyMoveResultFilenames()

Method Detail

clone

public Object clone()

Specified by:

clone in interface JobEntryInterface

Overrides:

clone in class JobEntryBase

getXML

public String getXML()

Specified by:

getXML in interface JobEntryInterface

Overrides:

getXML in class JobEntryBase

loadXML

public void loadXML(Node entrynode,
                    List<DatabaseMeta> databases,
                    List<SlaveServer> slaveServers,
                    Repository rep)
             throws KettleXMLException

Specified by:

loadXML in interface JobEntryInterface

Throws:

KettleXMLException

loadRep

public void loadRep(Repository rep,
                    ObjectId id_jobentry,
                    List<DatabaseMeta> databases,
                    List<SlaveServer> slaveServers)
             throws KettleException

Specified by:

loadRep in interface JobEntryInterface

Overrides:

loadRep in class JobEntryBase

Throws:

KettleException

saveRep

public void saveRep(Repository rep,
                    ObjectId id_job)
             throws KettleException

Specified by:

saveRep in interface JobEntryInterface

Overrides:

saveRep in class JobEntryBase

Throws:

KettleException

setSpecifyWildcard

public void setSpecifyWildcard(boolean specifywildcard)

isSpecifyWildcard

public boolean isSpecifyWildcard()

setFoldername

public void setFoldername(String foldername)

getFoldername

public String getFoldername()

getWildcard

public String getWildcard()

getWildcardExclude

public String getWildcardExclude()

getRealWildcard

public String getRealWildcard()

setWildcard

public void setWildcard(String wildcard)

setWildcardExclude

public void setWildcardExclude(String wildcardexclude)

setAddDate

public void setAddDate(boolean adddate)

isAddDate

public boolean isAddDate()

setAddTime

public void setAddTime(boolean addtime)

isAddTime

public boolean isAddTime()

setAddDateBeforeExtension

public void setAddDateBeforeExtension(boolean AddDateBeforeExtension)

isAddDateBeforeExtension

public boolean isAddDateBeforeExtension()

isOverwriteFile

public boolean isOverwriteFile()

setOverwriteFile

public void setOverwriteFile(boolean OverwriteFile)

setCreateDestinationFolder

public void setCreateDestinationFolder(boolean CreateDestinationFolder)

isCreateDestinationFolder

public boolean isCreateDestinationFolder()

isRemovedSourceFilename

public boolean isRemovedSourceFilename()

setRemovedSourceFilename

public void setRemovedSourceFilename(boolean RemovedSourceFilename)

setAddDestinationFilename

public void setAddDestinationFilename(boolean AddDestinationFilename)

isAddDestinationFilename

public boolean isAddDestinationFilename()

isSpecifyFormat

public boolean isSpecifyFormat()

setSpecifyFormat

public void setSpecifyFormat(boolean SpecifyFormat)

setDestinationFolder

public void setDestinationFolder(String destinationFolder)

getDestinationFolder

public String getDestinationFolder()

setNrErrorsLessThan

public void setNrErrorsLessThan(String nr_errors_less_than)

getNrErrorsLessThan

public String getNrErrorsLessThan()

setSuccessCondition

public void setSuccessCondition(String success_condition)

getSuccessCondition

public String getSuccessCondition()

setAction

public void setAction(String action)

getAction

public String getAction()

getDateTimeFormat

public String getDateTimeFormat()

setDateTimeFormat

public void setDateTimeFormat(String date_time_format)

execute

public Result execute(Result previousResult,
                      int nr)

Specified by:

execute in interface JobEntryInterface

evaluates

public boolean evaluates()

Description copied from class: JobEntryBase

check whether or not this job entry evaluates.

Specified by:

evaluates in interface JobEntryInterface

Overrides:

evaluates in class JobEntryBase

Returns:

true if the job entry evaluates

check

public void check(List<CheckResultInterface> remarks,
                  JobMeta jobMeta)

Description copied from class: JobEntryBase

Support for overrides not having to put in a check method

Specified by:

check in interface JobEntryInterface

Overrides:

check in class JobEntryBase

Parameters:

remarks - CheckResults from checking the job entry

jobMeta - JobMeta information letting threading back to the JobMeta possible