Package org.pentaho.di.cluster

Class ClusterSchema

java.lang.Object
org.pentaho.di.core.changed.ChangedFlag
org.pentaho.di.cluster.ClusterSchema
All Implemented Interfaces:
Cloneable, ChangedFlagInterface, org.pentaho.di.core.variables.VariableSpace, org.pentaho.di.core.xml.XMLInterface, org.pentaho.di.repository.RepositoryElementInterface, org.pentaho.di.repository.RepositoryObjectInterface, org.pentaho.di.shared.SharedObjectInterface
public class ClusterSchema extends ChangedFlag implements Cloneable, org.pentaho.di.shared.SharedObjectInterface, org.pentaho.di.core.variables.VariableSpace, org.pentaho.di.repository.RepositoryElementInterface, org.pentaho.di.core.xml.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 Details

    • XML_TAG

      public static final String XML_TAG
      See Also:

    • REPOSITORY_ELEMENT_TYPE

      public static final org.pentaho.di.repository.RepositoryObjectType REPOSITORY_ELEMENT_TYPE

  • Constructor Details

    • ClusterSchema

      public ClusterSchema()

    • ClusterSchema

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

    • ClusterSchema

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

  • Method Details

    • 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()
      Specified by:
      getXML in interface org.pentaho.di.shared.SharedObjectInterface
      Specified by:
      getXML in interface org.pentaho.di.core.xml.XMLInterface

    • getName

      public String getName()
      Specified by:
      getName in interface org.pentaho.di.repository.RepositoryElementInterface
      Specified by:
      getName in interface org.pentaho.di.repository.RepositoryObjectInterface
      Specified by:
      getName in interface org.pentaho.di.shared.SharedObjectInterface
      Returns:
      the name

    • setName

      public void setName(String name)
      Specified by:
      setName in interface org.pentaho.di.repository.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 org.pentaho.di.shared.SharedObjectInterface
      Returns:
      the shared

    • setShared

      public void setShared(boolean shared)
      Specified by:
      setShared in interface org.pentaho.di.shared.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 org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.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 org.pentaho.di.repository.ObjectId getObjectId()
      Specified by:
      getObjectId in interface org.pentaho.di.repository.RepositoryElementInterface
      Specified by:
      getObjectId in interface org.pentaho.di.repository.RepositoryObjectInterface

    • setObjectId

      public void setObjectId(org.pentaho.di.repository.ObjectId id)
      Specified by:
      setObjectId in interface org.pentaho.di.repository.RepositoryElementInterface

    • copyVariablesFrom

      public void copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
      Specified by:
      copyVariablesFrom in interface org.pentaho.di.core.variables.VariableSpace

    • environmentSubstitute

      public String environmentSubstitute(String aString)
      Specified by:
      environmentSubstitute in interface org.pentaho.di.core.variables.VariableSpace

    • environmentSubstitute

      public String[] environmentSubstitute(String[] aString)
      Specified by:
      environmentSubstitute in interface org.pentaho.di.core.variables.VariableSpace

    • fieldSubstitute

      public String fieldSubstitute(String aString, org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] rowData) throws org.pentaho.di.core.exception.KettleValueException
      Specified by:
      fieldSubstitute in interface org.pentaho.di.core.variables.VariableSpace
      Throws:
      org.pentaho.di.core.exception.KettleValueException

    • getParentVariableSpace

      public org.pentaho.di.core.variables.VariableSpace getParentVariableSpace()
      Specified by:
      getParentVariableSpace in interface org.pentaho.di.core.variables.VariableSpace

    • setParentVariableSpace

      public void setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
      Specified by:
      setParentVariableSpace in interface org.pentaho.di.core.variables.VariableSpace

    • getVariable

      public String getVariable(String variableName, String defaultValue)
      Specified by:
      getVariable in interface org.pentaho.di.core.variables.VariableSpace

    • getVariable

      public String getVariable(String variableName)
      Specified by:
      getVariable in interface org.pentaho.di.core.variables.VariableSpace

    • getBooleanValueOfVariable

      public boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
      Specified by:
      getBooleanValueOfVariable in interface org.pentaho.di.core.variables.VariableSpace

    • initializeVariablesFrom

      public void initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
      Specified by:
      initializeVariablesFrom in interface org.pentaho.di.core.variables.VariableSpace

    • listVariables

      public String[] listVariables()
      Specified by:
      listVariables in interface org.pentaho.di.core.variables.VariableSpace

    • setVariable

      public void setVariable(String variableName, String variableValue)
      Specified by:
      setVariable in interface org.pentaho.di.core.variables.VariableSpace

    • shareVariablesWith

      public void shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
      Specified by:
      shareVariablesWith in interface org.pentaho.di.core.variables.VariableSpace

    • injectVariables

      public void injectVariables(Map<String,String> prop)
      Specified by:
      injectVariables in interface org.pentaho.di.core.variables.VariableSpace

    • 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 org.pentaho.di.core.exception.KettleException
      Returns:
      A list of dynamic slave servers, retrieved from the first master server that was available.
      Throws:
      org.pentaho.di.core.exception.KettleException - when none of the masters can be contacted.

    • getRepositoryDirectory

      public org.pentaho.di.repository.RepositoryDirectoryInterface getRepositoryDirectory()
      Not supported for Partition schema, return the root.
      Specified by:
      getRepositoryDirectory in interface org.pentaho.di.repository.RepositoryElementInterface

    • setRepositoryDirectory

      public void setRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory)
      Specified by:
      setRepositoryDirectory in interface org.pentaho.di.repository.RepositoryElementInterface

    • getRepositoryElementType

      public org.pentaho.di.repository.RepositoryObjectType getRepositoryElementType()
      Specified by:
      getRepositoryElementType in interface org.pentaho.di.repository.RepositoryElementInterface

    • getObjectRevision

      public org.pentaho.di.repository.ObjectRevision getObjectRevision()
      Specified by:
      getObjectRevision in interface org.pentaho.di.repository.RepositoryElementInterface

    • setObjectRevision

      public void setObjectRevision(org.pentaho.di.repository.ObjectRevision objectRevision)
      Specified by:
      setObjectRevision in interface org.pentaho.di.repository.RepositoryElementInterface

    • getDescription

      public String getDescription()
      Specified by:
      getDescription in interface org.pentaho.di.repository.RepositoryElementInterface

    • setDescription

      public void setDescription(String description)
      Specified by:
      setDescription in interface org.pentaho.di.repository.RepositoryElementInterface

    • getChangedDate

      public Date getChangedDate()
      Specified by:
      getChangedDate in interface org.pentaho.di.shared.SharedObjectInterface
      Returns:
      the changedDate

    • setChangedDate

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