|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Uses of Job in org.pentaho.di.job |
---|
Methods in org.pentaho.di.job that return Job | |
---|---|
static Job |
Job.createJobWithNewClassLoader()
|
Job |
Job.getParentJob()
|
Methods in org.pentaho.di.job with parameters of type Job | |
---|---|
void |
JobListener.jobFinished(Job job)
|
void |
Job.setParentJob(Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.abort |
---|
Methods in org.pentaho.di.job.entries.abort with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryAbort.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
Execute this job entry and return the result. |
Uses of Job in org.pentaho.di.job.entries.addresultfilenames |
---|
Methods in org.pentaho.di.job.entries.addresultfilenames with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryAddResultFilenames.execute(org.pentaho.di.core.Result result,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.columnsexist |
---|
Methods in org.pentaho.di.job.entries.columnsexist with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryColumnsExist.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.connectedtorepository |
---|
Methods in org.pentaho.di.job.entries.connectedtorepository with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryConnectedToRepository.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
Execute this job entry and return the result. |
Uses of Job in org.pentaho.di.job.entries.copyfiles |
---|
Methods in org.pentaho.di.job.entries.copyfiles with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryCopyFiles.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.copymoveresultfilenames |
---|
Methods in org.pentaho.di.job.entries.copymoveresultfilenames with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryCopyMoveResultFilenames.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.createfile |
---|
Methods in org.pentaho.di.job.entries.createfile with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryCreateFile.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.createfolder |
---|
Methods in org.pentaho.di.job.entries.createfolder with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryCreateFolder.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.delay |
---|
Methods in org.pentaho.di.job.entries.delay with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryDelay.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
Execute this job entry and return the result. |
Uses of Job in org.pentaho.di.job.entries.deletefile |
---|
Methods in org.pentaho.di.job.entries.deletefile with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryDeleteFile.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.deletefiles |
---|
Methods in org.pentaho.di.job.entries.deletefiles with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryDeleteFiles.execute(org.pentaho.di.core.Result result,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.deletefolders |
---|
Methods in org.pentaho.di.job.entries.deletefolders with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryDeleteFolders.execute(org.pentaho.di.core.Result result,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.deleteresultfilenames |
---|
Methods in org.pentaho.di.job.entries.deleteresultfilenames with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryDeleteResultFilenames.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.dtdvalidator |
---|
Methods in org.pentaho.di.job.entries.dtdvalidator with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryDTDValidator.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.empty |
---|
Methods in org.pentaho.di.job.entries.empty with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryEmpty.execute(org.pentaho.di.core.Result prev_result,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.eval |
---|
Methods in org.pentaho.di.job.entries.eval with parameters of type Job | |
---|---|
boolean |
JobEntryEval.evaluate(org.pentaho.di.core.Result result,
Job parentJob,
org.pentaho.di.core.Result prev_result)
Evaluate the result of the execution of previous job entry. |
org.pentaho.di.core.Result |
JobEntryEval.execute(org.pentaho.di.core.Result prev_result,
int nr,
Repository rep,
Job parentJob)
Execute this job entry and return the result. |
Uses of Job in org.pentaho.di.job.entries.evaluatetablecontent |
---|
Methods in org.pentaho.di.job.entries.evaluatetablecontent with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryEvalTableContent.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.exportrepository |
---|
Methods in org.pentaho.di.job.entries.exportrepository with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryExportRepository.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.filecompare |
---|
Methods in org.pentaho.di.job.entries.filecompare with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryFileCompare.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.fileexists |
---|
Methods in org.pentaho.di.job.entries.fileexists with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryFileExists.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.filesexist |
---|
Methods in org.pentaho.di.job.entries.filesexist with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryFilesExist.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.folderisempty |
---|
Methods in org.pentaho.di.job.entries.folderisempty with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryFolderIsEmpty.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.folderscompare |
---|
Methods in org.pentaho.di.job.entries.folderscompare with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryFoldersCompare.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.ftp |
---|
Methods in org.pentaho.di.job.entries.ftp with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryFTP.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.ftpdelete |
---|
Methods in org.pentaho.di.job.entries.ftpdelete with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryFTPDelete.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.ftpput |
---|
Methods in org.pentaho.di.job.entries.ftpput with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryFTPPUT.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.getpop |
---|
Methods in org.pentaho.di.job.entries.getpop with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryGetPOP.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.http |
---|
Methods in org.pentaho.di.job.entries.http with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryHTTP.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
We made this one synchronized in the JVM because otherwise, this is not thread safe. |
Uses of Job in org.pentaho.di.job.entries.job |
---|
Methods in org.pentaho.di.job.entries.job that return Job | |
---|---|
Job |
JobEntryJobRunner.getJob()
|
Methods in org.pentaho.di.job.entries.job with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryJob.execute(org.pentaho.di.core.Result result,
int nr,
Repository rep,
Job parentJob)
|
void |
JobEntryJobRunner.setJob(Job job)
|
Constructors in org.pentaho.di.job.entries.job with parameters of type Job | |
---|---|
JobEntryJobRunner(Job job,
org.pentaho.di.core.Result result,
int entryNr)
|
Uses of Job in org.pentaho.di.job.entries.mail |
---|
Methods in org.pentaho.di.job.entries.mail with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryMail.execute(org.pentaho.di.core.Result result,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.mailvalidator |
---|
Methods in org.pentaho.di.job.entries.mailvalidator with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryMailValidator.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
Execute this job entry and return the result. |
Uses of Job in org.pentaho.di.job.entries.movefiles |
---|
Methods in org.pentaho.di.job.entries.movefiles with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryMoveFiles.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.msaccessbulkload |
---|
Methods in org.pentaho.di.job.entries.msaccessbulkload with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryMSAccessBulkLoad.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.msgboxinfo |
---|
Methods in org.pentaho.di.job.entries.msgboxinfo with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryMsgBoxInfo.execute(org.pentaho.di.core.Result prev_result,
int nr,
Repository rep,
Job parentJob)
Execute this job entry and return the result. |
Uses of Job in org.pentaho.di.job.entries.mssqlbulkload |
---|
Methods in org.pentaho.di.job.entries.mssqlbulkload with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryMssqlBulkLoad.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.mysqlbulkfile |
---|
Methods in org.pentaho.di.job.entries.mysqlbulkfile with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryMysqlBulkFile.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.mysqlbulkload |
---|
Methods in org.pentaho.di.job.entries.mysqlbulkload with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryMysqlBulkLoad.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.ping |
---|
Methods in org.pentaho.di.job.entries.ping with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryPing.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.setvariables |
---|
Methods in org.pentaho.di.job.entries.setvariables with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySetVariables.execute(org.pentaho.di.core.Result result,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.sftp |
---|
Methods in org.pentaho.di.job.entries.sftp with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySFTP.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.sftpput |
---|
Methods in org.pentaho.di.job.entries.sftpput with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySFTPPUT.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.shell |
---|
Methods in org.pentaho.di.job.entries.shell with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryShell.execute(org.pentaho.di.core.Result result,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.simpleeval |
---|
Methods in org.pentaho.di.job.entries.simpleeval with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySimpleEval.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.snmptrap |
---|
Methods in org.pentaho.di.job.entries.snmptrap with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySNMPTrap.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.special |
---|
Methods in org.pentaho.di.job.entries.special with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySpecial.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.sql |
---|
Methods in org.pentaho.di.job.entries.sql with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySQL.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.ssh2get |
---|
Methods in org.pentaho.di.job.entries.ssh2get with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySSH2GET.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.ssh2put |
---|
Methods in org.pentaho.di.job.entries.ssh2put with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySSH2PUT.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.success |
---|
Methods in org.pentaho.di.job.entries.success with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntrySuccess.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
Execute this job entry and return the result. |
Uses of Job in org.pentaho.di.job.entries.tableexists |
---|
Methods in org.pentaho.di.job.entries.tableexists with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryTableExists.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.trans |
---|
Methods in org.pentaho.di.job.entries.trans with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryTrans.execute(org.pentaho.di.core.Result result,
int nr,
Repository rep,
Job parentJob)
Execute this job entry and return the result. |
Uses of Job in org.pentaho.di.job.entries.truncatetables |
---|
Methods in org.pentaho.di.job.entries.truncatetables with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryTruncateTables.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.unzip |
---|
Methods in org.pentaho.di.job.entries.unzip with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryUnZip.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.waitforfile |
---|
Methods in org.pentaho.di.job.entries.waitforfile with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryWaitForFile.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.waitforsql |
---|
Methods in org.pentaho.di.job.entries.waitforsql with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryWaitForSQL.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.writetolog |
---|
Methods in org.pentaho.di.job.entries.writetolog with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryWriteToLog.execute(org.pentaho.di.core.Result prev_result,
int nr,
Repository rep,
Job parentJob)
Execute this job entry and return the result. |
Uses of Job in org.pentaho.di.job.entries.xmlwellformed |
---|
Methods in org.pentaho.di.job.entries.xmlwellformed with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryXMLWellFormed.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.xsdvalidator |
---|
Methods in org.pentaho.di.job.entries.xsdvalidator with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryXSDValidator.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.xslt |
---|
Methods in org.pentaho.di.job.entries.xslt with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryXSLT.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.job.entries.zipfile |
---|
Methods in org.pentaho.di.job.entries.zipfile with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryZipFile.execute(org.pentaho.di.core.Result previousResult,
int nr,
Repository rep,
Job parentJob)
|
boolean |
JobEntryZipFile.processRowFile(Job parentJob,
org.pentaho.di.core.Result result,
String realZipfilename,
String realWildcard,
String realWildcardExclude,
String realSourceDirectoryOrFile,
String realMovetodirectory,
boolean createparentfolder)
|
Uses of Job in org.pentaho.di.job.entry |
---|
Methods in org.pentaho.di.job.entry with parameters of type Job | |
---|---|
org.pentaho.di.core.Result |
JobEntryInterface.execute(org.pentaho.di.core.Result prev_result,
int nr,
Repository rep,
Job parentJob)
|
Uses of Job in org.pentaho.di.trans |
---|
Methods in org.pentaho.di.trans that return Job | |
---|---|
Job |
Trans.getParentJob()
|
Methods in org.pentaho.di.trans with parameters of type Job | |
---|---|
static org.pentaho.di.core.Result |
Trans.getClusteredTransformationResult(String logSubject,
TransSplitter transSplitter,
Job parentJob)
|
static long |
Trans.monitorClusteredTransformation(String logSubject,
TransSplitter transSplitter,
Job parentJob)
Consider that all the transformations in a cluster schema are running now... Now we should verify that they are all running as they should. If a transformation has an error, we should kill them all.. This should happen in a separate thread to prevent blocking of the UI. When the master and slave transformations have all finished, we should also run a cleanup on those transformations to release sockets, etc. |
static long |
Trans.monitorClusteredTransformation(String logSubject,
TransSplitter transSplitter,
Job parentJob,
int sleepTimeSeconds)
Consider that all the transformations in a cluster schema are running now... Now we should verify that they are all running as they should. If a transformation has an error, we should kill them all.. This should happen in a separate thread to prevent blocking of the UI. When the master and slave transformations have all finished, we should also run a cleanup on those transformations to release sockets, etc. |
void |
Trans.setParentJob(Job parentJob)
|
Uses of Job in org.pentaho.di.www |
---|
Methods in org.pentaho.di.www that return Job | |
---|---|
Job |
JobMap.getJob(String jobName)
|
Methods in org.pentaho.di.www with parameters of type Job | |
---|---|
void |
JobMap.addJob(String jobName,
Job job,
JobConfiguration jobConfiguration)
|
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |