|
||||||||||
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.ssh2get.JobEntrySSH2GET
public class JobEntrySSH2GET
This defines a SSH2 GET job entry.
Constructor Summary | |
---|---|
JobEntrySSH2GET()
|
|
JobEntrySSH2GET(String n)
|
Method Summary | |
---|---|
void |
check(List<CheckResultInterface> remarks,
JobMeta jobMeta)
Support for overrides not having to put in a check method. |
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 previousResult,
int nr)
Execute the job entry. |
boolean |
FileExists(String filename)
Check existence of a local file |
String |
getAfterFTPPut()
|
String |
getDestinationFolder()
|
long |
getFileSize(com.trilead.ssh2.SFTPv3Client sftpClient,
String filename)
Returns the file size of a file |
String |
getFtpDirectory()
|
String |
getHTTPProxyHost()
|
String |
getHTTPProxyPassword()
|
String |
getHTTPProxyPort()
|
String |
getHTTPProxyUsername()
|
String |
getKeyFilename()
|
String |
getKeyFilePass()
|
String |
getlocalDirectory()
|
String |
getPassword()
|
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Gets a list of all the resource dependencies that the step is depending on. |
String |
getServerName()
|
String |
getServerPort()
|
int |
getTimeout()
|
String |
getUserName()
|
String |
getWildcard()
|
String |
getXML()
This method is called by PDI whenever a job entry needs to serialize its settings to XML. |
boolean |
isCacheHostKey()
|
boolean |
isCreateDestinationFolder()
|
boolean |
isCreateTargetFolder()
|
boolean |
isDirectory(com.trilead.ssh2.SFTPv3Client sftpClient,
String filename)
Checks if file is a directory |
boolean |
isFile(com.trilead.ssh2.SFTPv3Client sftpClient,
String filename)
Checks if file is a file |
boolean |
isIncludeSubFolders()
|
boolean |
isOnlyGettingNewFiles()
|
boolean |
isUseBasicAuthentication()
|
boolean |
isUseHTTPProxy()
|
boolean |
isUsePublicKey()
|
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 |
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 |
setAfterFTPPut(String afterFtpPut)
|
void |
setCacheHostKey(boolean cachehostkeyin)
|
void |
setCreateDestinationFolder(boolean createdestinationfolderin)
|
void |
setCreateTargetFolder(boolean createtargetfolderin)
|
void |
setDestinationFolder(String destinationfolderin)
|
void |
setFtpDirectory(String directory)
|
void |
setHTTPProxyHost(String proxyhost)
|
void |
setHTTPProxyPassword(String proxyPassword)
|
void |
setHTTPProxyPort(String proxyport)
|
void |
setHTTPProxyUsername(String proxyusername)
|
void |
setIncludeSubFolders(boolean includeSubFolders)
|
void |
setKeyFilename(String keyfilename)
|
void |
setKeyFilePass(String keyFilePass)
|
void |
setlocalDirectory(String localDirectory)
|
void |
setOnlyGettingNewFiles(boolean onlyGettingNewFiles)
|
void |
setPassword(String password)
|
void |
setServerName(String serverName)
|
void |
setServerPort(String serverPort)
|
void |
setTimeout(int timeout)
|
void |
setUseBasicAuthentication(boolean useBasicAuthentication)
|
void |
setUseHTTPProxy(boolean httpproxy)
|
void |
setUsePublicKey(boolean publickey)
|
void |
setUserName(String userName)
|
void |
setWildcard(String wildcard)
|
boolean |
sshDirectoryExists(com.trilead.ssh2.SFTPv3Client sftpClient,
String directory)
Checks if a directory exists |
boolean |
sshFileExists(com.trilead.ssh2.SFTPv3Client sftpClient,
String filename)
Check existence of a file |
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, 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 |
Constructor Detail |
---|
public JobEntrySSH2GET(String n)
public JobEntrySSH2GET()
Method Detail |
---|
public Object clone()
JobEntryBase
clone
in interface JobEntryInterface
clone
in class JobEntryBase
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 String getFtpDirectory()
public void setFtpDirectory(String directory)
directory
- The directory to set.public String getPassword()
public void setPassword(String password)
password
- The password to set.public String getAfterFTPPut()
public void setAfterFTPPut(String afterFtpPut)
afterFtpPut
- The action after (FTP/SSH) transfer to executepublic void setHTTPProxyPassword(String proxyPassword)
proxyPassword
- The httpproxypassword to set.public String getHTTPProxyPassword()
public void setKeyFilePass(String keyFilePass)
keyFilePass
- The key file pass to set.public String getKeyFilePass()
public String getServerName()
public void setServerName(String serverName)
serverName
- The serverName to set.public void setHTTPProxyHost(String proxyhost)
proxyhost
- The httpproxyhost to set.public String getHTTPProxyHost()
public void setKeyFilename(String keyfilename)
keyfilename
- The key filename to set.public String getKeyFilename()
public String getUserName()
public void setUserName(String userName)
userName
- The userName to set.public void setHTTPProxyUsername(String proxyusername)
proxyusername
- The httpproxyusername to set.public String getHTTPProxyUsername()
public String getWildcard()
public void setWildcard(String wildcard)
wildcard
- The wildcard to set.public String getlocalDirectory()
public void setlocalDirectory(String localDirectory)
localDirectory
- The localDirectory to set.public boolean isOnlyGettingNewFiles()
public void setOnlyGettingNewFiles(boolean onlyGettingNewFiles)
onlyGettingNewFiles
- The onlyGettingNewFiles to set.public void setCacheHostKey(boolean cachehostkeyin)
cachehostkeyin
- The cachehostkey to set.public boolean isCacheHostKey()
public void setUseHTTPProxy(boolean httpproxy)
httpproxy
- The usehttpproxy to set.public boolean isUseHTTPProxy()
public boolean isUseBasicAuthentication()
public void setUseBasicAuthentication(boolean useBasicAuthentication)
useBasicAuthentication
- The use basic authentication flag to set.public void setIncludeSubFolders(boolean includeSubFolders)
includeSubFolders
- The include sub folders flag to set.public boolean isIncludeSubFolders()
public void setCreateDestinationFolder(boolean createdestinationfolderin)
createdestinationfolderin
- The createdestinationfolder to set.public boolean isCreateDestinationFolder()
public boolean isCreateTargetFolder()
public void setCreateTargetFolder(boolean createtargetfolderin)
createtargetfolderin
- The createtargetfolder to set.public void setUsePublicKey(boolean publickey)
publickey
- The publicpublickey to set.public boolean isUsePublicKey()
public String getServerPort()
public void setServerPort(String serverPort)
public void setHTTPProxyPort(String proxyport)
public String getHTTPProxyPort()
public void setDestinationFolder(String destinationfolderin)
public String getDestinationFolder()
public void setTimeout(int timeout)
timeout
- The timeout to set.public int getTimeout()
public Result execute(Result previousResult, int nr)
JobEntryInterface
execute
in interface JobEntryInterface
previousResult
- the previous resultnr
- the number of rows
public boolean sshFileExists(com.trilead.ssh2.SFTPv3Client sftpClient, String filename)
sftpClient
- filename
-
Exception
public boolean FileExists(String filename)
filename
-
public boolean isDirectory(com.trilead.ssh2.SFTPv3Client sftpClient, String filename)
sftpClient
- filename
-
public boolean sshDirectoryExists(com.trilead.ssh2.SFTPv3Client sftpClient, String directory)
sftpClient
- directory
-
public long getFileSize(com.trilead.ssh2.SFTPv3Client sftpClient, String filename) throws Exception
sftpClient
- filename
-
Exception
public boolean isFile(com.trilead.ssh2.SFTPv3Client sftpClient, String filename)
sftpClient
- filename
-
public boolean evaluates()
JobEntryBase
evaluates
in interface JobEntryInterface
evaluates
in class JobEntryBase
public List<ResourceReference> getResourceDependencies(JobMeta jobMeta)
JobEntryBase
getResourceDependencies
in interface JobEntryInterface
getResourceDependencies
in class JobEntryBase
ResourceReference
public 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 possible
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |