|
||||||||||
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.unzip.JobEntryUnZip
public class JobEntryUnZip
This defines a 'unzip' job entry. Its main use would be to unzip files in a directory
Field Summary | |
---|---|
int |
afterunzip
|
static int |
IF_FILE_EXISTS_FAIL
|
static int |
IF_FILE_EXISTS_OVERWRITE
|
static int |
IF_FILE_EXISTS_OVERWRITE_DIFF_SIZE
|
static int |
IF_FILE_EXISTS_OVERWRITE_EQUAL_SIZE
|
static int |
IF_FILE_EXISTS_OVERWRITE_ZIP_BIG
|
static int |
IF_FILE_EXISTS_OVERWRITE_ZIP_BIG_EQUAL
|
static int |
IF_FILE_EXISTS_OVERWRITE_ZIP_SMALL
|
static int |
IF_FILE_EXISTS_OVERWRITE_ZIP_SMALL_EQUAL
|
static int |
IF_FILE_EXISTS_SKIP
|
static int |
IF_FILE_EXISTS_UNIQ
|
String |
SUCCESS_IF_AT_LEAST_X_FILES_UN_ZIPPED
|
String |
SUCCESS_IF_ERRORS_LESS
|
String |
SUCCESS_IF_NO_ERRORS
|
static String[] |
typeIfFileExistsCode
|
static String[] |
typeIfFileExistsDesc
|
Constructor Summary | |
---|---|
JobEntryUnZip()
|
|
JobEntryUnZip(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 |
getDatafromprevious()
|
String |
getDateTimeFormat()
|
int |
getIfFileExist()
|
static String |
getIfFileExistsCode(int i)
|
static int |
getIfFileExistsInt(String desc)
|
String |
getLimit()
|
String |
getMoveToDirectory()
|
String |
getSourceDirectory()
|
String |
getSuccessCondition()
|
String |
getWildcard()
|
String |
getWildcardExclude()
|
String |
getWildcardSource()
|
String |
getXML()
This method is called by PDI whenever a job entry needs to serialize its settings to XML. |
String |
getZipFilename()
|
boolean |
isAddFileToResult()
|
boolean |
isCreateFolder()
|
boolean |
isCreateMoveToDirectory()
|
boolean |
isCreateRootFolder()
|
boolean |
isDateInFilename()
|
boolean |
isOriginalModificationDate()
|
boolean |
isOriginalTimestamp()
|
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. |
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 |
setAddFileToResult(boolean addfiletoresultin)
|
void |
setAddOriginalTimestamp(boolean addOriginalTimestamp)
|
void |
setCreateFolder(boolean createfolder)
|
void |
setCreateMoveToDirectory(boolean createMoveToDirectory)
|
void |
setCreateRootFolder(boolean rootzip)
|
void |
setDatafromprevious(boolean isfromprevious)
|
void |
setDateInFilename(boolean adddate)
|
void |
setDateTimeFormat(String date_time_format)
|
void |
setIfFileExists(int iffileexist)
|
void |
setLimit(String nr_limitin)
|
void |
setMoveToDirectory(String movetodirectory)
|
void |
setOriginalModificationDate(boolean setOriginalModificationDate)
|
void |
setSourceDirectory(String targetdirectoryin)
|
void |
setSpecifyFormat(boolean SpecifyFormat)
|
void |
setSuccessCondition(String success_condition)
|
void |
setTimeInFilename(boolean addtime)
|
void |
setWildcard(String wildcard)
|
void |
setWildcardExclude(String wildcardexclude)
|
void |
setWildcardSource(String wildcardSource)
|
void |
setZipFilename(String zipFilename)
|
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 |
---|
public int afterunzip
public String SUCCESS_IF_AT_LEAST_X_FILES_UN_ZIPPED
public String SUCCESS_IF_ERRORS_LESS
public String SUCCESS_IF_NO_ERRORS
public static final int IF_FILE_EXISTS_SKIP
public static final int IF_FILE_EXISTS_OVERWRITE
public static final int IF_FILE_EXISTS_UNIQ
public static final int IF_FILE_EXISTS_FAIL
public static final int IF_FILE_EXISTS_OVERWRITE_DIFF_SIZE
public static final int IF_FILE_EXISTS_OVERWRITE_EQUAL_SIZE
public static final int IF_FILE_EXISTS_OVERWRITE_ZIP_BIG
public static final int IF_FILE_EXISTS_OVERWRITE_ZIP_BIG_EQUAL
public static final int IF_FILE_EXISTS_OVERWRITE_ZIP_SMALL
public static final int IF_FILE_EXISTS_OVERWRITE_ZIP_SMALL_EQUAL
public static final String[] typeIfFileExistsCode
public static final String[] typeIfFileExistsDesc
Constructor Detail |
---|
public JobEntryUnZip(String n)
public JobEntryUnZip()
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 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 static final int getIfFileExistsInt(String desc)
public static final String getIfFileExistsCode(int i)
public int getIfFileExist()
public void setIfFileExists(int iffileexist)
setIfFileExist
- The iffileexist to set.public boolean isCreateMoveToDirectory()
public void setCreateMoveToDirectory(boolean createMoveToDirectory)
public void setZipFilename(String zipFilename)
public void setWildcard(String wildcard)
public void setWildcardExclude(String wildcardexclude)
public void setSourceDirectory(String targetdirectoryin)
public void setMoveToDirectory(String movetodirectory)
public String getSourceDirectory()
public String getMoveToDirectory()
public String getZipFilename()
public String getWildcardSource()
public void setWildcardSource(String wildcardSource)
public String getWildcard()
public String getWildcardExclude()
public void setAddFileToResult(boolean addfiletoresultin)
public boolean isAddFileToResult()
public void setDateInFilename(boolean adddate)
public void setAddOriginalTimestamp(boolean addOriginalTimestamp)
public boolean isOriginalTimestamp()
public void setOriginalModificationDate(boolean setOriginalModificationDate)
public boolean isOriginalModificationDate()
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 void setDatafromprevious(boolean isfromprevious)
public boolean getDatafromprevious()
public void setCreateRootFolder(boolean rootzip)
public boolean isCreateRootFolder()
public void setCreateFolder(boolean createfolder)
public boolean isCreateFolder()
public void setLimit(String nr_limitin)
public String getLimit()
public void setSuccessCondition(String success_condition)
public String getSuccessCondition()
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 |