|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.pentaho.di.www.TransformationMap
public class TransformationMap
This is a map between the transformation name and the (running/waiting/finished) transformation.
Constructor Summary | |
---|---|
TransformationMap()
|
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public TransformationMap()
Method Detail |
---|
public void addTransformation(String transformationName, String containerObjectId, Trans trans, TransConfiguration transConfiguration)
transformationName
- The name of the transformation to addcontainerObjectId
- the unique ID of the transformation in this container.trans
- The transformation to addtransConfiguration
- the transformation configuration to addpublic Trans getTransformation(String transformationName)
transformationName
-
public Trans getTransformation(CarteObjectEntry entry)
entry
- The Carte transformation object
public TransConfiguration getConfiguration(String transformationName)
transformationName
-
public TransConfiguration getConfiguration(CarteObjectEntry entry)
entry
- The Carte transformation object
public void removeTransformation(CarteObjectEntry entry)
entry
- the Carte object entrypublic List<CarteObjectEntry> getTransformationObjects()
public Map<CarteObjectEntry,TransConfiguration> getConfigurationMap()
public void setConfigurationMap(Map<CarteObjectEntry,TransConfiguration> configurationMap)
configurationMap
- the configurationMap to setpublic SocketPortAllocation allocateServerSocketPort(int portRangeStart, String hostname, String clusteredRunId, String transformationName, String sourceSlaveName, String sourceStepName, String sourceStepCopy, String targetSlaveName, String targetStepName, String targetStepCopy)
portRangeStart
- the start of the port range as described in the used cluster
schemahostname
- the host name to allocate this address forclusteredRunId
- A unique id, created for each new clustered run during transformation split.transformationName
- sourceStepName
- sourceStepCopy
-
public void deallocateServerSocketPorts(String transName, String carteObjectId)
transName
- the transformation name to releasecarteObjectId
- the carte object ID to referencepublic void deallocateServerSocketPorts(CarteObjectEntry entry)
entry
- the transformation object entry name to release the sockets forpublic void deallocateServerSocketPort(int port, String hostname)
public CarteObjectEntry getFirstCarteObjectEntry(String transName)
public SlaveServerConfig getSlaveServerConfig()
public void setSlaveServerConfig(SlaveServerConfig slaveServerConfig)
slaveServerConfig
- the slaveServerConfig to setpublic Map<String,List<SocketPortAllocation>> getHostServerSocketPortsMap()
public void setHostServerSocketPortsMap(Map<String,List<SocketPortAllocation>> hostServerSocketPortsMap)
hostServerSocketPortsMap
- the hostServerSocketPortsMap to setpublic SlaveSequence getSlaveSequence(String name)
public boolean isAutomaticSlaveSequenceCreationAllowed()
public SlaveSequence createSlaveSequence(String name) throws KettleException
KettleException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |