org.pentaho.di.trans.cluster
Class TransSplitter
java.lang.Object
org.pentaho.di.trans.cluster.TransSplitter
public class TransSplitter
- extends Object
This class takes care of the separation of the original transformation into pieces that run on the different slave servers in the clusters used.
- Author:
- Matt
TransSplitter
public TransSplitter()
TransSplitter
public TransSplitter(TransMeta transMeta)
throws KettleException
- Parameters:
originalTransformation
-
- Throws:
KettleException
getOriginalTransformation
public TransMeta getOriginalTransformation()
- Returns:
- the originalTransformation
setOriginalTransformation
public void setOriginalTransformation(TransMeta originalTransformation)
- Parameters:
originalTransformation
- the originalTransformation to set
createPortCacheKey
public String createPortCacheKey(SlaveServer sourceSlave,
String sourceStepName,
int sourceStepCopy,
SlaveServer targetSlave,
String targetStepName,
int targetStepCopy)
createSlavePartitionSchemaName
public static String createSlavePartitionSchemaName(String name)
createTargetPartitionSchemaName
public static String createTargetPartitionSchemaName(String name)
createPartitionSchemaNameFromTarget
public static String createPartitionSchemaNameFromTarget(String targetName)
getMaster
public TransMeta getMaster()
- Returns:
- the master
getSlaveTransMap
public Map<SlaveServer,TransMeta> getSlaveTransMap()
- Returns:
- the slaveTransMap : the mapping between a slaveServer and the transformation
getSlaves
public TransMeta[] getSlaves()
getSlaveTargets
public SlaveServer[] getSlaveTargets()
getMasterServer
public SlaveServer getMasterServer()
throws KettleException
- Throws:
KettleException
splitOriginalTransformation
public void splitOriginalTransformation()
throws KettleException
- Throws:
KettleException
getCarteObjectMap
public Map<TransMeta,String> getCarteObjectMap()
getClusteredRunId
public String getClusteredRunId()