org.pentaho.di.base

Class AbstractBaseCommandExecutor

java.lang.Object

org.pentaho.di.base.AbstractBaseCommandExecutor

Direct Known Subclasses:

KitchenCommandExecutor, PanCommandExecutor

public abstract class AbstractBaseCommandExecutor
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	YES

Constructor Summary

Constructors

Constructor and Description
AbstractBaseCommandExecutor()

Method Summary

Modifier and Type	Method and Description
protected int	calculateAndPrintElapsedTime(Date start, Date stop, String startStopMsgTkn, String processingEndAfterMsgTkn, String processingEndAfterLongMsgTkn, String processingEndAfterLongerMsgTkn, String processingEndAfterLongestMsgTkn)
protected String[]	convert(Map<String,String> map)
org.pentaho.metastore.stores.delegate.DelegatingMetaStore	createDefaultMetastore()
File	decodeBase64ToZipFile(Serializable base64Zip, boolean deleteOnJvmExit) Decodes the provided base64String into a default path.
File	decodeBase64ToZipFile(Serializable base64Zip, String filePath) Decodes the provided base64String into the specified filePath.
Repository	establishRepositoryConnection(RepositoryMeta repositoryMeta, String username, String password, RepositoryOperation... operations)
protected Result	exitWithStatus(int exitStatus)
SimpleDateFormat	getDateFormat()
LogChannelInterface	getLog()
org.pentaho.metastore.stores.delegate.DelegatingMetaStore	getMetaStore()
Class<?>	getPkgClazz()
Result	getResult()
boolean	isEnabled(String value)
RepositoryMeta	loadRepositoryConnection(String repoName, String loadingAvailableRepMsgTkn, String noRepsDefinedMsgTkn, String findingRepMsgTkn)
RepositoryDirectoryInterface	loadRepositoryDirectory(Repository repository, String dirName, String noRepoProvidedMsgTkn, String allocateAndConnectRepoMsgTkn, String cannotFindDirMsgTkn)
RepositoriesMeta	loadRepositoryInfo(String loadingAvailableRepMsgTkn, String noRepsDefinedMsgTkn)
protected void	logDebug(String messageKey)
protected void	logDebug(String messageKey, String... messageTokens)
protected void	printParameter(String name, String value, String defaultValue, String description)
void	printRepositoryDirectories(Repository repository, RepositoryDirectoryInterface directory)
protected void	printVersion(String kettleVersionMsgTkn)
void	setDateFormat(SimpleDateFormat dateFormat)
void	setLog(LogChannelInterface log)
void	setMetaStore(org.pentaho.metastore.stores.delegate.DelegatingMetaStore metaStore)
void	setPkgClazz(Class<?> pkgClazz)
void	setResult(Result result)

Methods inherited from class java.lang.Object

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

Field Detail

YES

public static final String YES

See Also:

Constant Field Values

Constructor Detail

AbstractBaseCommandExecutor

public AbstractBaseCommandExecutor()

Method Detail

exitWithStatus

protected Result exitWithStatus(int exitStatus)

createDefaultMetastore

public org.pentaho.metastore.stores.delegate.DelegatingMetaStore createDefaultMetastore()
                                                                                 throws org.pentaho.metastore.api.exceptions.MetaStoreException

Throws:

org.pentaho.metastore.api.exceptions.MetaStoreException

logDebug

protected void logDebug(String messageKey)

logDebug

protected void logDebug(String messageKey,
                        String... messageTokens)

calculateAndPrintElapsedTime

protected int calculateAndPrintElapsedTime(Date start,
                                           Date stop,
                                           String startStopMsgTkn,
                                           String processingEndAfterMsgTkn,
                                           String processingEndAfterLongMsgTkn,
                                           String processingEndAfterLongerMsgTkn,
                                           String processingEndAfterLongestMsgTkn)

printVersion

protected void printVersion(String kettleVersionMsgTkn)

loadRepositoryConnection

public RepositoryMeta loadRepositoryConnection(String repoName,
                                               String loadingAvailableRepMsgTkn,
                                               String noRepsDefinedMsgTkn,
                                               String findingRepMsgTkn)
                                        throws KettleException

Throws:

KettleException

loadRepositoryInfo

public RepositoriesMeta loadRepositoryInfo(String loadingAvailableRepMsgTkn,
                                           String noRepsDefinedMsgTkn)
                                    throws KettleException

Throws:

KettleException

loadRepositoryDirectory

public RepositoryDirectoryInterface loadRepositoryDirectory(Repository repository,
                                                            String dirName,
                                                            String noRepoProvidedMsgTkn,
                                                            String allocateAndConnectRepoMsgTkn,
                                                            String cannotFindDirMsgTkn)
                                                     throws KettleException

Throws:

KettleException

establishRepositoryConnection

public Repository establishRepositoryConnection(RepositoryMeta repositoryMeta,
                                                String username,
                                                String password,
                                                RepositoryOperation... operations)
                                         throws KettleException

Throws:

KettleException

printRepositoryDirectories

public void printRepositoryDirectories(Repository repository,
                                       RepositoryDirectoryInterface directory)
                                throws KettleException

Throws:

KettleException

printParameter

protected void printParameter(String name,
                              String value,
                              String defaultValue,
                              String description)

convert

protected String[] convert(Map<String,String> map)

isEnabled

public boolean isEnabled(String value)

decodeBase64ToZipFile

public File decodeBase64ToZipFile(Serializable base64Zip,
                                  boolean deleteOnJvmExit)
                           throws IOException

Decodes the provided base64String into a default path. Resulting zip file is UUID-named for concurrency sake.

Parameters:

base64Zip - BASE64 representation of a file

deleteOnJvmExit - true if we want this newly generated file to be marked for deletion on JVM termination, false otherwise

Returns:

File the newly created File

Throws:

IOException

decodeBase64ToZipFile

public File decodeBase64ToZipFile(Serializable base64Zip,
                                  String filePath)
                           throws IOException

Decodes the provided base64String into the specified filePath. Parent directories must already exist.

Parameters:

base64Zip - BASE64 representation of a file

filePath - String The path to which the base64String is to be decoded

Returns:

File the newly created File

Throws:

IOException

getLog

public LogChannelInterface getLog()

setLog

public void setLog(LogChannelInterface log)

getPkgClazz

public Class<?> getPkgClazz()

setPkgClazz

public void setPkgClazz(Class<?> pkgClazz)

getMetaStore

public org.pentaho.metastore.stores.delegate.DelegatingMetaStore getMetaStore()

setMetaStore

public void setMetaStore(org.pentaho.metastore.stores.delegate.DelegatingMetaStore metaStore)

getDateFormat

public SimpleDateFormat getDateFormat()

setDateFormat

public void setDateFormat(SimpleDateFormat dateFormat)

getResult

public Result getResult()

setResult

public void setResult(Result result)