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 and Description
KitchenCommandExecutor(Class<?> pkgClazz)
KitchenCommandExecutor(Class<?> pkgClazz, LogChannelInterface log)
KitchenCommandExecutor(Class<?> pkgClazz, LogChannelInterface log, Future<KettleException> kettleInit)

Method Summary

Modifier and Type	Method and Description
Result	execute(Params params)
Result	execute(Params params, String[] arguments)
protected void	executeRepositoryBasedCommand(Repository repository, String dirName, String listJobs, String listDirs)
Future<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, RepositoryDirectoryInterface directory)
int	printVersion()
void	setKettleInit(Future<KettleException> kettleInit)

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

KitchenCommandExecutor

public KitchenCommandExecutor(Class<?> pkgClazz)

KitchenCommandExecutor

public KitchenCommandExecutor(Class<?> pkgClazz,
                              LogChannelInterface log)

KitchenCommandExecutor

public KitchenCommandExecutor(Class<?> pkgClazz,
                              LogChannelInterface log,
                              Future<KettleException> kettleInit)

Method Detail

execute

public Result execute(Params params)
               throws Throwable

Throws:

Throwable

execute

public Result execute(Params params,
                      String[] arguments)
               throws Throwable

Throws:

Throwable

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 UnknownParamException

Throws:

UnknownParamException

printRepositoryStoredJobs

protected void printRepositoryStoredJobs(Repository repository,
                                         RepositoryDirectoryInterface directory)
                                  throws KettleException

Throws:

KettleException

printRepositories

protected void printRepositories(RepositoriesMeta repositoriesMeta)

getKettleInit

public Future<KettleException> getKettleInit()

setKettleInit

public void setKettleInit(Future<KettleException> kettleInit)