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
int	execute(String repoName, String noRepo, String username, String trustUser, String password, String dirName, String filename, String jobName, String listJobs, String listDirs, String exportRepo, String initialDir, String listRepos, String listParams, NamedParams params, NamedParams customParams, String[] arguments)
Job	executeFilesystemBasedCommand(String initialDir, String filename)
Job	executeRepositoryBasedCommand(Repository repository, RepositoryMeta repositoryMeta, String dirName, String jobName, String listJobs, String listDirs)
Future<KettleException>	getKettleInit()
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, createDefaultMetastore, establishRepositoryConnection, getDateFormat, getLog, getMetaStore, getPkgClazz, isEnabled, loadRepositoryConnection, loadRepositoryInfo, logDebug, logDebug, printParameter, printRepositoryDirectories, printVersion, setDateFormat, setLog, setMetaStore, setPkgClazz

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 int execute(String repoName,
                   String noRepo,
                   String username,
                   String trustUser,
                   String password,
                   String dirName,
                   String filename,
                   String jobName,
                   String listJobs,
                   String listDirs,
                   String exportRepo,
                   String initialDir,
                   String listRepos,
                   String listParams,
                   NamedParams params,
                   NamedParams customParams,
                   String[] arguments)
            throws Throwable

Throws:

Throwable

printVersion

public int printVersion()

executeRepositoryBasedCommand

public Job executeRepositoryBasedCommand(Repository repository,
                                         RepositoryMeta repositoryMeta,
                                         String dirName,
                                         String jobName,
                                         String listJobs,
                                         String listDirs)
                                  throws Exception

Throws:

Exception

executeFilesystemBasedCommand

public Job executeFilesystemBasedCommand(String initialDir,
                                         String filename)
                                  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)