org.pentaho.di.cluster
Class ClusterSchema

java.lang.Object
  extended by org.pentaho.di.core.changed.ChangedFlag
      extended by org.pentaho.di.cluster.ClusterSchema
All Implemented Interfaces:
Cloneable, ChangedFlagInterface, VariableSpace, XMLInterface, RepositoryElementInterface, RepositoryObjectInterface, SharedObjectInterface

public class ClusterSchema
extends ChangedFlag
implements Cloneable, SharedObjectInterface, VariableSpace, RepositoryElementInterface, XMLInterface

A cluster schema combines a list of slave servers so that they can be set altogether. It (can) also contain a number of performance tuning options regarding this cluster. For example options regarding communications with the master node of the nodes themselves come to mind.

Since:
17-nov-2006
Author:
Matt

Field Summary
static RepositoryObjectType REPOSITORY_ELEMENT_TYPE
           
static String XML_TAG
           
 
Constructor Summary
ClusterSchema()
           
ClusterSchema(Node clusterSchemaNode, List<SlaveServer> referenceSlaveServers)
           
ClusterSchema(String name, List<SlaveServer> slaveServers)
           
 
Method Summary
 ClusterSchema 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)
           
 SlaveServer findMaster()
           
 int findNrSlaves()
           
 SlaveServer findSlaveServer(String slaveServerName)
           
 String getBasePort()
           
 boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
          This method returns a boolean for the new variable check boxes.
 Date getChangedDate()
           
 String getDescription()
           
 String getName()
          The name of the repository object
 ObjectId getObjectId()
          The id of the object
 ObjectRevision getObjectRevision()
           
 VariableSpace getParentVariableSpace()
          Get the parent of the variable space.
 RepositoryDirectoryInterface getRepositoryDirectory()
          Not supported for Partition schema, return the root.
 RepositoryObjectType getRepositoryElementType()
           
 List<SlaveServer> getSlaveServers()
           
 List<SlaveServer> getSlaveServersFromMasterOrLocal()
           
 String[] getSlaveServerStrings()
           
 String getSocketsBufferSize()
           
 String getSocketsFlushInterval()
           
 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 getXML()
          Describes the Object implementing this interface as XML
 int hashCode()
           
 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.
 boolean isDynamic()
           
 boolean isShared()
           
 boolean isSocketsCompressed()
           
 String[] listVariables()
          List the variables (not the values) that are currently in the variable space.
 void replaceMeta(ClusterSchema clusterSchema)
           
 void setBasePort(String basePort)
           
 void setChangedDate(Date changedDate)
           
 void setDescription(String description)
           
 void setDynamic(boolean dynamic)
           
 void setName(String name)
           
 void setObjectId(ObjectId id)
           
 void setObjectRevision(ObjectRevision objectRevision)
           
 void setParentVariableSpace(VariableSpace parent)
          Set the parent variable space
 void setRepositoryDirectory(RepositoryDirectoryInterface repositoryDirectory)
           
 void setShared(boolean shared)
           
 void setSlaveServers(List<SlaveServer> slaveServers)
           
 void setSocketsBufferSize(String socketsBufferSize)
           
 void setSocketsCompressed(boolean socketsCompressed)
           
 void setSocketsFlushInterval(String socketFlushInterval)
           
 void setVariable(String variableName, String variableValue)
          Sets a variable in the Kettle Variables list.
 void shareVariablesWith(VariableSpace space)
          Share a variable space from another variable space.
 String toString()
           
 
Methods inherited from class org.pentaho.di.core.changed.ChangedFlag
addObserver, clearChanged, deleteObserver, hasChanged, notifyObservers, setChanged, setChanged
 
Methods inherited from class java.lang.Object
getClass, notify, notifyAll, wait, wait, wait
 

Field Detail

XML_TAG

public static final String XML_TAG
See Also:
Constant Field Values

REPOSITORY_ELEMENT_TYPE

public static final RepositoryObjectType REPOSITORY_ELEMENT_TYPE
Constructor Detail

ClusterSchema

public ClusterSchema()

ClusterSchema

public ClusterSchema(String name,
                     List<SlaveServer> slaveServers)
Parameters:
name -
slaveServers -

ClusterSchema

public ClusterSchema(Node clusterSchemaNode,
                     List<SlaveServer> referenceSlaveServers)
Method Detail

clone

public ClusterSchema clone()
Overrides:
clone in class Object

replaceMeta

public void replaceMeta(ClusterSchema clusterSchema)

toString

public String toString()
Overrides:
toString in class Object

equals

public boolean equals(Object obj)
Overrides:
equals in class Object

hashCode

public int hashCode()
Overrides:
hashCode in class Object

getXML

public String getXML()
Description copied from interface: XMLInterface
Describes the Object implementing this interface as XML

Specified by:
getXML in interface XMLInterface
Specified by:
getXML in interface SharedObjectInterface
Returns:
the XML string for this object

getName

public String getName()
Description copied from interface: RepositoryObjectInterface
The name of the repository object

Specified by:
getName in interface RepositoryElementInterface
Specified by:
getName in interface RepositoryObjectInterface
Specified by:
getName in interface SharedObjectInterface
Returns:
the name

setName

public void setName(String name)
Specified by:
setName in interface RepositoryElementInterface
Parameters:
name - the name to set

getSlaveServers

public List<SlaveServer> getSlaveServers()
Returns:
the internal (static) list of slave servers

setSlaveServers

public void setSlaveServers(List<SlaveServer> slaveServers)
Parameters:
slaveServers - the slaveServers to set

getSlaveServerStrings

public String[] getSlaveServerStrings()
Returns:
The slave server strings from this cluster schema

isShared

public boolean isShared()
Specified by:
isShared in interface SharedObjectInterface
Returns:
the shared

setShared

public void setShared(boolean shared)
Specified by:
setShared in interface SharedObjectInterface
Parameters:
shared - the shared to set

getBasePort

public String getBasePort()
Returns:
the basePort

setBasePort

public void setBasePort(String basePort)
Parameters:
basePort - the basePort to set

findMaster

public SlaveServer findMaster()
                       throws KettleException
Throws:
KettleException

findNrSlaves

public int findNrSlaves()
Returns:
The number of slave servers, excluding the master server

getSocketsFlushInterval

public String getSocketsFlushInterval()
Returns:
the socketFlushInterval

setSocketsFlushInterval

public void setSocketsFlushInterval(String socketFlushInterval)
Parameters:
socketFlushInterval - the socketFlushInterval to set

getSocketsBufferSize

public String getSocketsBufferSize()
Returns:
the socketsBufferSize

setSocketsBufferSize

public void setSocketsBufferSize(String socketsBufferSize)
Parameters:
socketsBufferSize - the socketsBufferSize to set

isSocketsCompressed

public boolean isSocketsCompressed()
Returns:
the socketsCompressed

setSocketsCompressed

public void setSocketsCompressed(boolean socketsCompressed)
Parameters:
socketsCompressed - the socketsCompressed to set

findSlaveServer

public SlaveServer findSlaveServer(String slaveServerName)

getObjectId

public ObjectId getObjectId()
Description copied from interface: RepositoryObjectInterface
The id of the object

Specified by:
getObjectId in interface RepositoryElementInterface
Specified by:
getObjectId in interface RepositoryObjectInterface
Returns:
the id of the object

setObjectId

public void setObjectId(ObjectId id)
Specified by:
setObjectId in interface RepositoryElementInterface

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.

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.

isDynamic

public boolean isDynamic()
Returns:
the dynamic

setDynamic

public void setDynamic(boolean dynamic)
Parameters:
dynamic - the dynamic to set

getSlaveServersFromMasterOrLocal

public List<SlaveServer> getSlaveServersFromMasterOrLocal()
                                                   throws KettleException
Returns:
A list of dynamic slave servers, retrieved from the first master server that was available.
Throws:
KettleException - when none of the masters can be contacted.

getRepositoryDirectory

public RepositoryDirectoryInterface getRepositoryDirectory()
Not supported for Partition schema, return the root.

Specified by:
getRepositoryDirectory in interface RepositoryElementInterface

setRepositoryDirectory

public void setRepositoryDirectory(RepositoryDirectoryInterface repositoryDirectory)
Specified by:
setRepositoryDirectory in interface RepositoryElementInterface

getRepositoryElementType

public RepositoryObjectType getRepositoryElementType()
Specified by:
getRepositoryElementType in interface RepositoryElementInterface

getObjectRevision

public ObjectRevision getObjectRevision()
Specified by:
getObjectRevision in interface RepositoryElementInterface

setObjectRevision

public void setObjectRevision(ObjectRevision objectRevision)
Specified by:
setObjectRevision in interface RepositoryElementInterface

getDescription

public String getDescription()
Specified by:
getDescription in interface RepositoryElementInterface

setDescription

public void setDescription(String description)
Specified by:
setDescription in interface RepositoryElementInterface

getChangedDate

public Date getChangedDate()
Specified by:
getChangedDate in interface SharedObjectInterface
Returns:
the changedDate

setChangedDate

public void setChangedDate(Date changedDate)
Parameters:
changedDate - the changedDate to set