Package org.pentaho.di.kitchen

Class KitchenCommandExecutor

java.lang.Object

org.pentaho.di.base.AbstractBaseCommandExecutor

org.pentaho.di.kitchen.KitchenCommandExecutor

public class KitchenCommandExecutor
extends AbstractBaseCommandExecutor

Field Summary

Fields inherited from class org.pentaho.di.base.AbstractBaseCommandExecutor

YES

Constructor Summary

Constructors

Constructor	Description
KitchenCommandExecutor(Class<?> pkgClazz)
KitchenCommandExecutor(Class<?> pkgClazz, org.pentaho.di.core.logging.LogChannelInterface log)
KitchenCommandExecutor(Class<?> pkgClazz, org.pentaho.di.core.logging.LogChannelInterface log, Future<org.pentaho.di.core.exception.KettleException> kettleInit)

Method Summary

Modifier and Type	Method	Description
org.pentaho.di.core.Result	execute(Params params)
org.pentaho.di.core.Result	execute(Params params, String[] arguments)
protected void	executeRepositoryBasedCommand(Repository repository, String dirName, String listJobs, String listDirs)
protected org.pentaho.di.core.Result	exitWithStatus(int exitStatus, Job job)
Future<org.pentaho.di.core.exception.KettleException>	getKettleInit()
Job	loadJobFromFilesystem(String initialDir, String filename, Serializable base64Zip)
Job	loadJobFromRepository(Repository repository, String dirName, String jobName)
protected void	printJobParameters(Job job)
protected void	printRepositories(RepositoriesMeta repositoriesMeta)
protected void	printRepositoryStoredJobs(Repository repository, org.pentaho.di.repository.RepositoryDirectoryInterface directory)
int	printVersion()
void	setKettleInit(Future<org.pentaho.di.core.exception.KettleException> kettleInit)

Methods inherited from class org.pentaho.di.base.AbstractBaseCommandExecutor

calculateAndPrintElapsedTime, convert, decodeBase64ToZipFile, decodeBase64ToZipFile, establishRepositoryConnection, exitWithStatus, getBowl, getDateFormat, getLog, getMetaStore, getPkgClazz, getResult, isEnabled, loadRepositoryConnection, loadRepositoryDirectory, loadRepositoryInfo, logDebug, logDebug, printParameter, printRepositoryDirectories, printVersion, setBowl, setDateFormat, setLog, setMetaStore, setPkgClazz, setResult, validateAndSetPluginContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

KitchenCommandExecutor

public KitchenCommandExecutor(Class<?> pkgClazz)

KitchenCommandExecutor

public KitchenCommandExecutor(Class<?> pkgClazz,
 org.pentaho.di.core.logging.LogChannelInterface log)

KitchenCommandExecutor

public KitchenCommandExecutor(Class<?> pkgClazz,
 org.pentaho.di.core.logging.LogChannelInterface log,
 Future<org.pentaho.di.core.exception.KettleException> kettleInit)

Method Details

execute

public org.pentaho.di.core.Result execute(Params params)
                                   throws Throwable

Throws:

Throwable

execute

public org.pentaho.di.core.Result execute(Params params,
 String[] arguments)
                                   throws Throwable

Throws:

Throwable

exitWithStatus

protected org.pentaho.di.core.Result exitWithStatus(int exitStatus,
 Job job)

printVersion

public int printVersion()

executeRepositoryBasedCommand

protected void executeRepositoryBasedCommand(Repository repository,
 String dirName,
 String listJobs,
 String listDirs)
                                      throws Exception

Throws:

Exception

loadJobFromRepository

public Job loadJobFromRepository(Repository repository,
 String dirName,
 String jobName)
                          throws Exception

Throws:

Exception

loadJobFromFilesystem

public Job loadJobFromFilesystem(String initialDir,
 String filename,
 Serializable base64Zip)
                          throws Exception

Throws:

Exception

printJobParameters

protected void printJobParameters(Job job)
                           throws org.pentaho.di.core.parameters.UnknownParamException

Throws:

org.pentaho.di.core.parameters.UnknownParamException

printRepositoryStoredJobs

protected void printRepositoryStoredJobs(Repository repository,
 org.pentaho.di.repository.RepositoryDirectoryInterface directory)
                                  throws org.pentaho.di.core.exception.KettleException

Throws:

org.pentaho.di.core.exception.KettleException

printRepositories

protected void printRepositories(RepositoriesMeta repositoriesMeta)

getKettleInit

public Future<org.pentaho.di.core.exception.KettleException> getKettleInit()

setKettleInit

public void setKettleInit(Future<org.pentaho.di.core.exception.KettleException> kettleInit)