org.pentaho.di.job.entries.sftpput
Class JobEntrySFTPPUT
java.lang.Object
org.pentaho.di.job.entry.JobEntryBase
org.pentaho.di.job.entries.sftpput.JobEntrySFTPPUT
- All Implemented Interfaces:
- Cloneable, org.pentaho.di.core.CheckResultSourceInterface, org.pentaho.di.core.variables.VariableSpace, JobEntryInterface, ResourceHolderInterface
public class JobEntrySFTPPUT
- extends JobEntryBase
- implements Cloneable, JobEntryInterface
This defines an SFTP put job entry.
- Since:
- 05-11-2003
- Author:
- Matt
Method Summary |
void |
check(List<org.pentaho.di.core.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. |
org.pentaho.di.core.Result |
execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
String |
getLocalDirectory()
|
String |
getPassword()
|
boolean |
getRemove()
|
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Get a list of all the resource dependencies that the step is depending
on. |
String |
getScpDirectory()
|
String |
getServerName()
|
String |
getServerPort()
|
String |
getUserName()
|
String |
getWildcard()
|
String |
getXML()
|
boolean |
isAddFilenameResut()
|
boolean |
isCopyPrevious()
|
void |
loadRep(Repository rep,
long id_jobentry,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers)
|
void |
loadXML(Node entrynode,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
|
void |
saveRep(Repository rep,
long id_job)
|
void |
setAddFilenameResut(boolean addFilenameResut)
|
void |
setCopyPrevious(boolean copyprevious)
|
void |
setLocalDirectory(String localDirectory)
|
void |
setPassword(String password)
|
void |
setRemove(boolean remove)
|
void |
setScpDirectory(String directory)
|
void |
setServerName(String serverName)
|
void |
setServerPort(String serverPort)
|
void |
setUserName(String userName)
|
void |
setWildcard(String wildcard)
|
Methods inherited from class org.pentaho.di.job.entry.JobEntryBase |
clear, copyVariablesFrom, environmentSubstitute, environmentSubstitute, exportResources, getBooleanValueOfVariable, getConfigId, getDescription, getDialogClassName, getFilename, getHolderType, getID, getJobEntryType, getName, getParentVariableSpace, getPluginID, getRealFilename, getSQLStatements, getSQLStatements, getTypeCode, getTypeCode, getTypeDesc, getTypeDesc, getTypeId, getUsedDatabaseConnections, getVariable, getVariable, hasChanged, initializeVariablesFrom, injectVariables, isDummy, isEvaluation, isFTP, isHTTP, isJob, isMail, isSFTP, isShell, isSpecial, isStart, isTransformation, isUnconditional, listVariables, loadXML, parseRepositoryObjects, resetErrorsBeforeExecution, setChanged, setChanged, setConfigId, setDescription, setID, setJobEntryType, setName, setParentVariableSpace, setPluginID, setVariable, shareVariablesWith, toString |
Methods inherited from interface org.pentaho.di.job.entry.JobEntryInterface |
clear, exportResources, getConfigId, getDescription, getDialogClassName, getFilename, getID, getJobEntryType, getName, getPluginID, getRealFilename, getSQLStatements, getSQLStatements, getTypeCode, getUsedDatabaseConnections, hasChanged, isDummy, isEvaluation, isJob, isMail, isShell, isSpecial, isStart, isTransformation, isUnconditional, resetErrorsBeforeExecution, setChanged, setChanged, setConfigId, setDescription, setID, setJobEntryType, setName, setPluginID |
JobEntrySFTPPUT
public JobEntrySFTPPUT(String n)
JobEntrySFTPPUT
public JobEntrySFTPPUT()
JobEntrySFTPPUT
public JobEntrySFTPPUT(JobEntryBase jeb)
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<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers,
Repository rep)
throws org.pentaho.di.core.exception.KettleXMLException
- Specified by:
loadXML
in interface JobEntryInterface
- Throws:
org.pentaho.di.core.exception.KettleXMLException
loadRep
public void loadRep(Repository rep,
long id_jobentry,
List<org.pentaho.di.core.database.DatabaseMeta> databases,
List<SlaveServer> slaveServers)
throws org.pentaho.di.core.exception.KettleException
- Specified by:
loadRep
in interface JobEntryInterface
- Overrides:
loadRep
in class JobEntryBase
- Throws:
org.pentaho.di.core.exception.KettleException
saveRep
public void saveRep(Repository rep,
long id_job)
throws org.pentaho.di.core.exception.KettleException
- Specified by:
saveRep
in interface JobEntryInterface
- Overrides:
saveRep
in class JobEntryBase
- Throws:
org.pentaho.di.core.exception.KettleException
getScpDirectory
public String getScpDirectory()
- Returns:
- Returns the directory.
setScpDirectory
public void setScpDirectory(String directory)
- Parameters:
directory
- The directory to set.
getPassword
public String getPassword()
- Returns:
- Returns the password.
setPassword
public void setPassword(String password)
- Parameters:
password
- The password to set.
getServerName
public String getServerName()
- Returns:
- Returns the serverName.
setServerName
public void setServerName(String serverName)
- Parameters:
serverName
- The serverName to set.
getUserName
public String getUserName()
- Returns:
- Returns the userName.
setUserName
public void setUserName(String userName)
- Parameters:
userName
- The userName to set.
getWildcard
public String getWildcard()
- Returns:
- Returns the wildcard.
setWildcard
public void setWildcard(String wildcard)
- Parameters:
wildcard
- The wildcard to set.
getLocalDirectory
public String getLocalDirectory()
- Returns:
- Returns the localdirectory.
setLocalDirectory
public void setLocalDirectory(String localDirectory)
- Parameters:
localDirectory
- The localDirectory to set.
setRemove
public void setRemove(boolean remove)
- Parameters:
remove
- The remove to set.
getRemove
public boolean getRemove()
- Returns:
- Returns the remove.
isCopyPrevious
public boolean isCopyPrevious()
setCopyPrevious
public void setCopyPrevious(boolean copyprevious)
isAddFilenameResut
public boolean isAddFilenameResut()
setAddFilenameResut
public void setAddFilenameResut(boolean addFilenameResut)
getServerPort
public String getServerPort()
setServerPort
public void setServerPort(String serverPort)
execute
public org.pentaho.di.core.Result execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
throws org.pentaho.di.core.exception.KettleException
- Specified by:
execute
in interface JobEntryInterface
- Throws:
org.pentaho.di.core.exception.KettleException
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
getResourceDependencies
public List<ResourceReference> getResourceDependencies(JobMeta jobMeta)
- Description copied from class:
JobEntryBase
- Get a list of all the resource dependencies that the step is depending
on.
- Specified by:
getResourceDependencies
in interface JobEntryInterface
- Overrides:
getResourceDependencies
in class JobEntryBase
- Returns:
- a list of all the resource dependencies that the step is
depending on
check
public void check(List<org.pentaho.di.core.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 entryjobMeta
- JobMeta information letting threading back to the JobMeta possible