|
||||||||||
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.ftpput.JobEntryFTPPUT
public class JobEntryFTPPUT
This defines an FTP put job entry.
Constructor Summary | |
---|---|
JobEntryFTPPUT()
|
|
JobEntryFTPPUT(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. |
String |
getControlEncoding()
Get the control encoding to be used for ftp'ing |
String |
getLocalDirectory()
|
String |
getPassword()
|
String |
getProxyHost()
|
String |
getProxyPassword()
|
String |
getProxyPort()
|
String |
getProxyUsername()
|
String |
getRemoteDirectory()
|
boolean |
getRemove()
|
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Gets a list of all the resource dependencies that the step is depending on. |
String |
getServerName()
|
String |
getServerPort()
|
String |
getSocksProxyHost()
|
String |
getSocksProxyPassword()
|
String |
getSocksProxyPort()
|
String |
getSocksProxyUsername()
|
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 |
isActiveConnection()
|
boolean |
isBinaryMode()
|
boolean |
isOnlyPuttingNewFiles()
|
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 |
setActiveConnection(boolean activeConnection)
|
void |
setBinaryMode(boolean binaryMode)
|
void |
setControlEncoding(String encoding)
Set the encoding to be used for ftp'ing. |
void |
setLocalDirectory(String directory)
|
void |
setOnlyPuttingNewFiles(boolean onlyPuttingNewFiles)
|
void |
setPassword(String password)
|
void |
setProxyHost(String proxyHost)
|
void |
setProxyPassword(String proxyPassword)
|
void |
setProxyPort(String proxyPort)
|
void |
setProxyUsername(String proxyUsername)
|
void |
setRemoteDirectory(String directory)
|
void |
setRemove(boolean remove)
|
void |
setServerName(String serverName)
|
void |
setServerPort(String serverPort)
|
void |
setSocksProxyHost(String socksProxyHost)
|
void |
setSocksProxyPassword(String socksProxyPassword)
|
void |
setSocksProxyPort(String socksProxyPort)
|
void |
setSocksProxyUsername(String socksProxyUsername)
|
void |
setTimeout(int timeout)
|
void |
setUserName(String userName)
|
void |
setWildcard(String wildcard)
|
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 JobEntryFTPPUT(String n)
public JobEntryFTPPUT()
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 boolean isBinaryMode()
public void setBinaryMode(boolean binaryMode)
binaryMode
- The binaryMode to set.public void setTimeout(int timeout)
timeout
- The timeout to set.public int getTimeout()
public boolean isOnlyPuttingNewFiles()
public void setOnlyPuttingNewFiles(boolean onlyPuttingNewFiles)
onlyPuttingNewFiles
- Only transfer new files to the remote hostpublic String getControlEncoding()
public void setControlEncoding(String encoding)
encoding
- The encoding to be used.public String getRemoteDirectory()
public void setRemoteDirectory(String directory)
directory
- The remoteDirectory to set.public String getPassword()
public void setPassword(String password)
password
- The password to set.public String getServerName()
public void setServerName(String serverName)
serverName
- The serverName to set.public String getUserName()
public void setUserName(String userName)
userName
- The userName to set.public String getWildcard()
public void setWildcard(String wildcard)
wildcard
- The wildcard to set.public String getLocalDirectory()
public void setLocalDirectory(String directory)
directory
- The localDirectory to set.public void setRemove(boolean remove)
remove
- The remove to set.public boolean getRemove()
public String getServerPort()
public void setServerPort(String serverPort)
public boolean isActiveConnection()
public void setActiveConnection(boolean activeConnection)
activeConnection
- set to true to get an active FTP connectionpublic String getProxyHost()
public void setProxyHost(String proxyHost)
proxyHost
- The hostname of the proxy.public String getProxyPassword()
public void setProxyPassword(String proxyPassword)
proxyPassword
- The password which is used to authenticate at the proxy.public String getProxyPort()
public void setProxyPort(String proxyPort)
proxyPort
- The port of the ftp-proxy.public String getProxyUsername()
public void setSocksProxyHost(String socksProxyHost)
socksProxyHost
- The socks proxy host to setpublic void setSocksProxyPort(String socksProxyPort)
socksProxyPort
- The socks proxy port to setpublic void setSocksProxyUsername(String socksProxyUsername)
socksProxyUsername
- The socks proxy username to setpublic void setSocksProxyPassword(String socksProxyPassword)
socksProxyPassword
- The socks proxy password to setpublic String getSocksProxyHost()
public String getSocksProxyPort()
public String getSocksProxyUsername()
public String getSocksProxyPassword()
public void setProxyUsername(String proxyUsername)
proxyUsername
- The username which is used to authenticate at the proxy.public Result execute(Result previousResult, int nr)
JobEntryInterface
execute
in interface JobEntryInterface
previousResult
- the previous resultnr
- the number of rows
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 |