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
Modifier and Type | Field and Description |
---|---|
static org.pentaho.di.repository.RepositoryObjectType |
REPOSITORY_ELEMENT_TYPE |
static String |
XML_TAG |
Constructor and Description |
---|
ClusterSchema() |
ClusterSchema(Node clusterSchemaNode,
List<SlaveServer> referenceSlaveServers) |
ClusterSchema(String name,
List<SlaveServer> slaveServers) |
Modifier and Type | Method and Description |
---|---|
ClusterSchema |
clone() |
void |
copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space) |
String |
environmentSubstitute(String aString) |
String[] |
environmentSubstitute(String[] aString) |
boolean |
equals(Object obj) |
String |
fieldSubstitute(String aString,
org.pentaho.di.core.row.RowMetaInterface rowMeta,
Object[] rowData) |
SlaveServer |
findMaster() |
int |
findNrSlaves() |
SlaveServer |
findSlaveServer(String slaveServerName) |
String |
getBasePort() |
boolean |
getBooleanValueOfVariable(String variableName,
boolean defaultValue) |
Date |
getChangedDate() |
String |
getDescription() |
String |
getName() |
org.pentaho.di.repository.ObjectId |
getObjectId() |
org.pentaho.di.repository.ObjectRevision |
getObjectRevision() |
org.pentaho.di.core.variables.VariableSpace |
getParentVariableSpace() |
org.pentaho.di.repository.RepositoryDirectoryInterface |
getRepositoryDirectory()
Not supported for Partition schema, return the root.
|
org.pentaho.di.repository.RepositoryObjectType |
getRepositoryElementType() |
List<SlaveServer> |
getSlaveServers() |
List<SlaveServer> |
getSlaveServersFromMasterOrLocal() |
String[] |
getSlaveServerStrings() |
String |
getSocketsBufferSize() |
String |
getSocketsFlushInterval() |
String |
getVariable(String variableName) |
String |
getVariable(String variableName,
String defaultValue) |
String |
getXML() |
int |
hashCode() |
void |
initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent) |
void |
injectVariables(Map<String,String> prop) |
boolean |
isDynamic() |
boolean |
isShared() |
boolean |
isSocketsCompressed() |
String[] |
listVariables() |
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(org.pentaho.di.repository.ObjectId id) |
void |
setObjectRevision(org.pentaho.di.repository.ObjectRevision objectRevision) |
void |
setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent) |
void |
setRepositoryDirectory(org.pentaho.di.repository.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) |
void |
shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space) |
String |
toString() |
addObserver, clearChanged, deleteObserver, hasChanged, notifyObservers, setChanged, setChanged
public static final String XML_TAG
public static final org.pentaho.di.repository.RepositoryObjectType REPOSITORY_ELEMENT_TYPE
public ClusterSchema()
public ClusterSchema(String name, List<SlaveServer> slaveServers)
name
- slaveServers
- public ClusterSchema(Node clusterSchemaNode, List<SlaveServer> referenceSlaveServers)
public ClusterSchema clone()
public void replaceMeta(ClusterSchema clusterSchema)
public String getXML()
getXML
in interface org.pentaho.di.core.xml.XMLInterface
getXML
in interface org.pentaho.di.shared.SharedObjectInterface
public String getName()
getName
in interface org.pentaho.di.repository.RepositoryElementInterface
getName
in interface org.pentaho.di.repository.RepositoryObjectInterface
getName
in interface org.pentaho.di.shared.SharedObjectInterface
public void setName(String name)
setName
in interface org.pentaho.di.repository.RepositoryElementInterface
name
- the name to setpublic List<SlaveServer> getSlaveServers()
public void setSlaveServers(List<SlaveServer> slaveServers)
slaveServers
- the slaveServers to setpublic String[] getSlaveServerStrings()
public boolean isShared()
isShared
in interface org.pentaho.di.shared.SharedObjectInterface
public void setShared(boolean shared)
setShared
in interface org.pentaho.di.shared.SharedObjectInterface
shared
- the shared to setpublic String getBasePort()
public void setBasePort(String basePort)
basePort
- the basePort to setpublic SlaveServer findMaster() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
public int findNrSlaves()
public String getSocketsFlushInterval()
public void setSocketsFlushInterval(String socketFlushInterval)
socketFlushInterval
- the socketFlushInterval to setpublic String getSocketsBufferSize()
public void setSocketsBufferSize(String socketsBufferSize)
socketsBufferSize
- the socketsBufferSize to setpublic boolean isSocketsCompressed()
public void setSocketsCompressed(boolean socketsCompressed)
socketsCompressed
- the socketsCompressed to setpublic SlaveServer findSlaveServer(String slaveServerName)
public org.pentaho.di.repository.ObjectId getObjectId()
getObjectId
in interface org.pentaho.di.repository.RepositoryElementInterface
getObjectId
in interface org.pentaho.di.repository.RepositoryObjectInterface
public void setObjectId(org.pentaho.di.repository.ObjectId id)
setObjectId
in interface org.pentaho.di.repository.RepositoryElementInterface
public void copyVariablesFrom(org.pentaho.di.core.variables.VariableSpace space)
copyVariablesFrom
in interface org.pentaho.di.core.variables.VariableSpace
public String environmentSubstitute(String aString)
environmentSubstitute
in interface org.pentaho.di.core.variables.VariableSpace
public String[] environmentSubstitute(String[] aString)
environmentSubstitute
in interface org.pentaho.di.core.variables.VariableSpace
public String fieldSubstitute(String aString, org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] rowData) throws org.pentaho.di.core.exception.KettleValueException
fieldSubstitute
in interface org.pentaho.di.core.variables.VariableSpace
org.pentaho.di.core.exception.KettleValueException
public org.pentaho.di.core.variables.VariableSpace getParentVariableSpace()
getParentVariableSpace
in interface org.pentaho.di.core.variables.VariableSpace
public void setParentVariableSpace(org.pentaho.di.core.variables.VariableSpace parent)
setParentVariableSpace
in interface org.pentaho.di.core.variables.VariableSpace
public String getVariable(String variableName, String defaultValue)
getVariable
in interface org.pentaho.di.core.variables.VariableSpace
public String getVariable(String variableName)
getVariable
in interface org.pentaho.di.core.variables.VariableSpace
public boolean getBooleanValueOfVariable(String variableName, boolean defaultValue)
getBooleanValueOfVariable
in interface org.pentaho.di.core.variables.VariableSpace
public void initializeVariablesFrom(org.pentaho.di.core.variables.VariableSpace parent)
initializeVariablesFrom
in interface org.pentaho.di.core.variables.VariableSpace
public String[] listVariables()
listVariables
in interface org.pentaho.di.core.variables.VariableSpace
public void setVariable(String variableName, String variableValue)
setVariable
in interface org.pentaho.di.core.variables.VariableSpace
public void shareVariablesWith(org.pentaho.di.core.variables.VariableSpace space)
shareVariablesWith
in interface org.pentaho.di.core.variables.VariableSpace
public void injectVariables(Map<String,String> prop)
injectVariables
in interface org.pentaho.di.core.variables.VariableSpace
public boolean isDynamic()
public void setDynamic(boolean dynamic)
dynamic
- the dynamic to setpublic List<SlaveServer> getSlaveServersFromMasterOrLocal() throws org.pentaho.di.core.exception.KettleException
org.pentaho.di.core.exception.KettleException
- when none of the masters can be contacted.public org.pentaho.di.repository.RepositoryDirectoryInterface getRepositoryDirectory()
getRepositoryDirectory
in interface org.pentaho.di.repository.RepositoryElementInterface
public void setRepositoryDirectory(org.pentaho.di.repository.RepositoryDirectoryInterface repositoryDirectory)
setRepositoryDirectory
in interface org.pentaho.di.repository.RepositoryElementInterface
public org.pentaho.di.repository.RepositoryObjectType getRepositoryElementType()
getRepositoryElementType
in interface org.pentaho.di.repository.RepositoryElementInterface
public org.pentaho.di.repository.ObjectRevision getObjectRevision()
getObjectRevision
in interface org.pentaho.di.repository.RepositoryElementInterface
public void setObjectRevision(org.pentaho.di.repository.ObjectRevision objectRevision)
setObjectRevision
in interface org.pentaho.di.repository.RepositoryElementInterface
public String getDescription()
getDescription
in interface org.pentaho.di.repository.RepositoryElementInterface
public void setDescription(String description)
setDescription
in interface org.pentaho.di.repository.RepositoryElementInterface
public Date getChangedDate()
getChangedDate
in interface org.pentaho.di.shared.SharedObjectInterface
public void setChangedDate(Date changedDate)
changedDate
- the changedDate to set