org.pentaho.di.core.namedcluster.model

Class NamedCluster

java.lang.Object

org.pentaho.di.core.namedcluster.model.NamedCluster

All Implemented Interfaces:

Cloneable, VariableSpace

public class NamedCluster
extends Object
implements Cloneable, VariableSpace

Field Summary

Fields

Modifier and Type	Field and Description
static Comparator<NamedCluster>	comparator

Constructor Summary

Constructors

Constructor and Description
NamedCluster()

Method Summary

Methods

Modifier and Type	Method and Description
NamedCluster	clone()
void	copyVariablesFrom(VariableSpace space) Copy the variables from another space, without initializing with the defaults.
String	environmentSubstitute(String aString) Substitute the string using the current variable space.
String[]	environmentSubstitute(String[] aString) Replaces environment variables in an array of strings.
boolean	equals(Object obj)
String	fieldSubstitute(String aString, RowMetaInterface rowMeta, Object[] rowData) Substitutes field values in aString.
boolean	getBooleanValueOfVariable(String variableName, boolean defaultValue) This method returns a boolean for the new variable check boxes.
String	getHdfsHost()
String	getHdfsPassword()
String	getHdfsPort()
String	getHdfsUsername()
String	getJobTrackerHost()
String	getJobTrackerPort()
long	getLastModifiedDate()
String	getName()
String	getOozieUrl()
VariableSpace	getParentVariableSpace() Get the parent of the variable space.
String	getVariable(String variableName) Get the value of a variable.
String	getVariable(String variableName, String defaultValue) Get the value of a variable with a default in case the variable is not found.
String	getZooKeeperHost()
String	getZooKeeperPort()
void	initializeVariablesFrom(VariableSpace parent) Initialize variable space using the defaults, copy over the variables from the parent (using copyVariablesFrom()), after this the "injected" variables should be inserted (injectVariables()).
void	injectVariables(Map<String,String> prop) Inject variables.
String[]	listVariables() List the variables (not the values) that are currently in the variable space.
void	replaceMeta(NamedCluster nc)
void	setHdfsHost(String hdfsHost)
void	setHdfsPassword(String hdfsPassword)
void	setHdfsPort(String hdfsPort)
void	setHdfsUsername(String hdfsUsername)
void	setJobTrackerHost(String jobTrackerHost)
void	setJobTrackerPort(String jobTrackerPort)
void	setLastModifiedDate(long lastModifiedDate)
void	setName(String name)
void	setOozieUrl(String oozieUrl)
void	setParentVariableSpace(VariableSpace parent) Set the parent variable space
void	setVariable(String variableName, String variableValue) Sets a variable in the Kettle Variables list.
void	setZooKeeperHost(String zooKeeperHost)
void	setZooKeeperPort(String zooKeeperPort)
void	shareVariablesWith(VariableSpace space) Share a variable space from another variable space.

Methods inherited from class java.lang.Object

getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

comparator

public static final Comparator<NamedCluster> comparator

Constructor Detail

NamedCluster

public NamedCluster()

Method Detail

setName

public void setName(String name)

getName

public String getName()

copyVariablesFrom

public void copyVariablesFrom(VariableSpace space)

Description copied from interface: VariableSpace

Copy the variables from another space, without initializing with the defaults. This does not affect any parent relationship.

Specified by:

copyVariablesFrom in interface VariableSpace

Parameters:

space - the space to copy the variables from.

environmentSubstitute

public String environmentSubstitute(String aString)

Description copied from interface: VariableSpace

Substitute the string using the current variable space.

Specified by:

environmentSubstitute in interface VariableSpace

Parameters:

aString - The string to substitute.

Returns:

The substituted string.

environmentSubstitute

public String[] environmentSubstitute(String[] aString)

Description copied from interface: VariableSpace

Replaces environment variables in an array of strings. See also: environmentSubstitute(String string)

Specified by:

environmentSubstitute in interface VariableSpace

Parameters:

aString - The array of strings that wants its variables to be replaced.

Returns:

the array with the environment variables replaced.

fieldSubstitute

public String fieldSubstitute(String aString,
                     RowMetaInterface rowMeta,
                     Object[] rowData)
                       throws KettleValueException

Description copied from interface: VariableSpace

Substitutes field values in aString. Field values are of the form "?{}". The values are retrieved from the specified row. Please note that the getString() method is used to convert to a String, for all values in the row.

Specified by:

fieldSubstitute in interface VariableSpace

Parameters:

aString - the string on which to apply the substitution.

rowMeta - The row metadata to use.

rowData - The row data to use

Returns:

the string with the substitution applied.

Throws:

KettleValueException - In case there is a String conversion error

getParentVariableSpace

public VariableSpace getParentVariableSpace()

Description copied from interface: VariableSpace

Get the parent of the variable space.

Specified by:

getParentVariableSpace in interface VariableSpace

Returns:

the parent.

setParentVariableSpace

public void setParentVariableSpace(VariableSpace parent)

Description copied from interface: VariableSpace

Set the parent variable space

Specified by:

setParentVariableSpace in interface VariableSpace

Parameters:

parent - The parent variable space to set

getVariable

public String getVariable(String variableName,
                 String defaultValue)

Description copied from interface: VariableSpace

Get the value of a variable with a default in case the variable is not found.

Specified by:

getVariable in interface VariableSpace

Parameters:

variableName - The name of the variable

defaultValue - The default value in case the variable could not be found

Returns:

the String value of a variable

getVariable

public String getVariable(String variableName)

Description copied from interface: VariableSpace

Get the value of a variable.

Specified by:

getVariable in interface VariableSpace

Parameters:

variableName - The name of the variable

Returns:

the String value of a variable or null in case the variable could not be found.

getBooleanValueOfVariable

public boolean getBooleanValueOfVariable(String variableName,
                                boolean defaultValue)

Description copied from interface: VariableSpace

This method returns a boolean for the new variable check boxes. If the variable name is not set or the variable name is not specified, this method simply returns the default value. If not, it convert the variable value to a boolean. "Y", "YES" and "TRUE" all convert to true. (case insensitive)

Specified by:

getBooleanValueOfVariable in interface VariableSpace

Parameters:

variableName - The variable to look up.

defaultValue - The default value to return.

Returns:

See Also:

static method ValueMeta.convertStringToBoolean()

initializeVariablesFrom

public void initializeVariablesFrom(VariableSpace parent)

Description copied from interface: VariableSpace

Initialize variable space using the defaults, copy over the variables from the parent (using copyVariablesFrom()), after this the "injected" variables should be inserted (injectVariables()). The parent is set as parent variable space.

Specified by:

initializeVariablesFrom in interface VariableSpace

Parameters:

parent - the parent to start from, or null if root.

listVariables

public String[] listVariables()

Description copied from interface: VariableSpace

List the variables (not the values) that are currently in the variable space.

Specified by:

listVariables in interface VariableSpace

Returns:

Array of String variable names.

setVariable

public void setVariable(String variableName,
               String variableValue)

Description copied from interface: VariableSpace

Sets a variable in the Kettle Variables list.

Specified by:

setVariable in interface VariableSpace

Parameters:

variableName - The name of the variable to set

variableValue - The value of the variable to set. If the variableValue is null, the variable is cleared from the list.

shareVariablesWith

public void shareVariablesWith(VariableSpace space)

Description copied from interface: VariableSpace

Share a variable space from another variable space. This means that the object should take over the space used as argument.

Specified by:

shareVariablesWith in interface VariableSpace

Parameters:

space - Variable space to be shared.

injectVariables

public void injectVariables(Map<String,String> prop)

Description copied from interface: VariableSpace

Inject variables. The behaviour should be that the properties object will be stored and at the time the VariableSpace is initialized (or upon calling this method if the space is already initialized). After injecting the link of the properties object should be removed.

Specified by:

injectVariables in interface VariableSpace

Parameters:

prop - Properties object containing key-value pairs.

replaceMeta

public void replaceMeta(NamedCluster nc)

clone

public NamedCluster clone()

Overrides:

clone in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

getHdfsHost

public String getHdfsHost()

setHdfsHost

public void setHdfsHost(String hdfsHost)

getHdfsPort

public String getHdfsPort()

setHdfsPort

public void setHdfsPort(String hdfsPort)

getHdfsUsername

public String getHdfsUsername()

setHdfsUsername

public void setHdfsUsername(String hdfsUsername)

getHdfsPassword

public String getHdfsPassword()

setHdfsPassword

public void setHdfsPassword(String hdfsPassword)

getJobTrackerHost

public String getJobTrackerHost()

setJobTrackerHost

public void setJobTrackerHost(String jobTrackerHost)

getJobTrackerPort

public String getJobTrackerPort()

setJobTrackerPort

public void setJobTrackerPort(String jobTrackerPort)

getZooKeeperHost

public String getZooKeeperHost()

setZooKeeperHost

public void setZooKeeperHost(String zooKeeperHost)

getZooKeeperPort

public String getZooKeeperPort()

setZooKeeperPort

public void setZooKeeperPort(String zooKeeperPort)

getOozieUrl

public String getOozieUrl()

setOozieUrl

public void setOozieUrl(String oozieUrl)

getLastModifiedDate

public long getLastModifiedDate()

setLastModifiedDate

public void setLastModifiedDate(long lastModifiedDate)