|
||||||||||
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.ftp.JobEntryFTP
public class JobEntryFTP
This defines an FTP job entry.
Constructor Summary | |
---|---|
JobEntryFTP()
|
|
JobEntryFTP(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 |
getDateTimeFormat()
|
String |
getFtpDirectory()
|
String |
getLimit()
|
String |
getMoveToDirectory()
|
String |
getPassword()
|
String |
getPort()
|
String |
getProxyHost()
|
String |
getProxyPassword()
|
String |
getProxyPort()
|
String |
getProxyUsername()
|
boolean |
getRemove()
|
List<ResourceReference> |
getResourceDependencies(JobMeta jobMeta)
Gets a list of all the resource dependencies that the step is depending on. |
String |
getServerName()
|
String |
getSocksProxyHost()
|
String |
getSocksProxyPassword()
|
String |
getSocksProxyPort()
|
String |
getSocksProxyUsername()
|
String |
getSuccessCondition()
|
String |
getTargetDirectory()
|
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 |
isAddDateBeforeExtension()
|
boolean |
isAddToResult()
|
boolean |
isBinaryMode()
|
boolean |
isCreateMoveFolder()
|
boolean |
isDateInFilename()
|
boolean |
isMoveFiles()
|
boolean |
isOnlyGettingNewFiles()
|
boolean |
isSpecifyFormat()
|
boolean |
isTimeInFilename()
|
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. |
String |
normalizePath(String path)
normalize / to \ and remove trailing slashes from a path |
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 passive)
|
void |
setAddDateBeforeExtension(boolean AddDateBeforeExtension)
|
void |
setAddToResult(boolean isaddresultin)
|
void |
setBinaryMode(boolean binaryMode)
|
void |
setControlEncoding(String encoding)
Set the encoding to be used for ftp'ing. |
void |
setCreateMoveFolder(boolean createmovefolderin)
|
void |
setDateInFilename(boolean adddate)
|
void |
setDateTimeFormat(String date_time_format)
|
void |
setFtpDirectory(String directory)
|
void |
setLimit(String nr_limitin)
|
void |
setMoveFiles(boolean movefilesin)
|
void |
setMoveToDirectory(String movetoin)
|
void |
setOnlyGettingNewFiles(boolean onlyGettingNewFilesin)
|
void |
setPassword(String password)
|
void |
setPort(String port)
|
void |
setProxyHost(String proxyHost)
|
void |
setProxyPassword(String proxyPassword)
|
void |
setProxyPort(String proxyPort)
|
void |
setProxyUsername(String proxyUsername)
|
void |
setRemove(boolean remove)
|
void |
setServerName(String serverName)
|
void |
setSocksProxyHost(String socksProxyHost)
|
void |
setSocksProxyPassword(String socksProxyPassword)
|
void |
setSocksProxyPort(String socksProxyPort)
|
void |
setSocksProxyUsername(String socksPoxyUsername)
|
void |
setSpecifyFormat(boolean SpecifyFormat)
|
void |
setSuccessCondition(String success_condition)
|
void |
setTargetDirectory(String targetDirectory)
|
void |
setTimeInFilename(boolean addtime)
|
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 |
Field Detail |
---|
public int ifFileExistsSkip
public String SifFileExistsSkip
public int ifFileExistsCreateUniq
public String SifFileExistsCreateUniq
public int ifFileExistsFail
public String SifFileExistsFail
public int ifFileExists
public String SifFileExists
public String SUCCESS_IF_AT_LEAST_X_FILES_DOWNLOADED
public String SUCCESS_IF_ERRORS_LESS
public String SUCCESS_IF_NO_ERRORS
Constructor Detail |
---|
public JobEntryFTP(String n)
public JobEntryFTP()
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 void setLimit(String nr_limitin)
public String getLimit()
public void setSuccessCondition(String success_condition)
public String getSuccessCondition()
public void setCreateMoveFolder(boolean createmovefolderin)
public boolean isCreateMoveFolder()
public void setAddDateBeforeExtension(boolean AddDateBeforeExtension)
public boolean isAddDateBeforeExtension()
public void setAddToResult(boolean isaddresultin)
public boolean isAddToResult()
public void setDateInFilename(boolean adddate)
public boolean isDateInFilename()
public void setTimeInFilename(boolean addtime)
public boolean isTimeInFilename()
public boolean isSpecifyFormat()
public void setSpecifyFormat(boolean SpecifyFormat)
public String getDateTimeFormat()
public void setDateTimeFormat(String date_time_format)
public boolean isMoveFiles()
public void setMoveFiles(boolean movefilesin)
movefilesin
- The movefiles to set.public String getMoveToDirectory()
public void setMoveToDirectory(String movetoin)
movetoin
- The movetodirectory to set.public boolean isBinaryMode()
public void setBinaryMode(boolean binaryMode)
binaryMode
- The binaryMode to set.public 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 getServerName()
public void setServerName(String serverName)
serverName
- The serverName to set.public String getPort()
public void setPort(String port)
port
- The port 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 getTargetDirectory()
public void setTargetDirectory(String targetDirectory)
targetDirectory
- The targetDirectory to set.public void setTimeout(int timeout)
timeout
- The timeout to set.public int getTimeout()
public void setRemove(boolean remove)
remove
- The remove to set.public boolean getRemove()
public boolean isOnlyGettingNewFiles()
public void setOnlyGettingNewFiles(boolean onlyGettingNewFilesin)
onlyGettingNewFiles
- The onlyGettingNewFiles to set.public String getControlEncoding()
public void setControlEncoding(String encoding)
encoding
- The encoding to be used.public String getProxyHost()
public void setProxyHost(String proxyHost)
proxyHost
- The hostname of the proxy.public void setProxyPassword(String proxyPassword)
proxyPassword
- The password which is used to authenticate at the socks proxy.public String getProxyPassword()
public void setSocksProxyPassword(String socksProxyPassword)
proxyPassword
- The password which is used to authenticate at the proxy.public String getSocksProxyPassword()
public void setProxyPort(String proxyPort)
proxyPort
- The port of the ftp-proxy.public String getProxyPort()
public String getProxyUsername()
public void setProxyUsername(String proxyUsername)
proxyUsername
- The username which is used to authenticate at the proxy.public String getSocksProxyUsername()
public void setSocksProxyUsername(String socksPoxyUsername)
proxyUsername
- The username which is used to authenticate at the socks proxy.public void setSocksProxyHost(String socksProxyHost)
socksProxyHost
- The host name of the socks proxy hostpublic String getSocksProxyHost()
public void setSocksProxyPort(String socksProxyPort)
socksProxyPort
- The port number the socks proxy host is usingpublic String getSocksProxyPort()
public Result execute(Result previousResult, int nr)
JobEntryInterface
execute
in interface JobEntryInterface
previousResult
- the previous resultnr
- the number of rows
public String normalizePath(String path) throws Exception
path
-
Exception
public boolean evaluates()
JobEntryBase
evaluates
in interface JobEntryInterface
evaluates
in class JobEntryBase
public boolean isActiveConnection()
public void setActiveConnection(boolean passive)
activeConnection
- the activeConnection to setpublic 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 possiblepublic List<ResourceReference> getResourceDependencies(JobMeta jobMeta)
JobEntryBase
getResourceDependencies
in interface JobEntryInterface
getResourceDependencies
in class JobEntryBase
ResourceReference
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |