Package org.pentaho.di.trans

Class SlaveStepCopyPartitionDistribution

java.lang.Object

org.pentaho.di.trans.SlaveStepCopyPartitionDistribution

public class SlaveStepCopyPartitionDistribution
extends Object

This class keeps track of which step copy in which transformation is responsible for handling a certain partition nr. This distribution is created BEFORE the slave transformations are sent to the slave servers. As such, it will be easy to link a step copy on a certain slave server uniquely to a certain partition. That is to say, it will be done the same way accross the complete cluster.

Author:

matt

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
class	SlaveStepCopyPartitionDistribution.SlaveStepCopy

Field Summary

Fields

Modifier and Type	Field	Description
static final String	XML_TAG

Constructor Summary

Constructors

Constructor	Description
SlaveStepCopyPartitionDistribution()
SlaveStepCopyPartitionDistribution(Node node)

Method Summary

Modifier and Type	Method	Description
int	addPartition(String slaveServerName, String partitionSchemaName, int stepCopyNr)	Add a partition number to the distribution if it doesn't already exist.
void	addPartition(String slaveServerName, String partitionSchemaName, int stepCopyNr, int partitionNr)	Add a partition number to the distribution for re-use at runtime.
boolean	equals(Object o)
Map<SlaveStepCopyPartitionDistribution.SlaveStepCopy,Integer>	getDistribution()
List<PartitionSchema>	getOriginalPartitionSchemas()
int	getPartition(String slaveServerName, String partitionSchemaName, int stepCopyNr)
String	getXML()
int	hashCode()
void	setOriginalPartitionSchemas(List<PartitionSchema> originalPartitionSchemas)

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

XML_TAG

public static final String XML_TAG

See Also:

• Constant Field Values

Constructor Details

SlaveStepCopyPartitionDistribution

public SlaveStepCopyPartitionDistribution()

SlaveStepCopyPartitionDistribution

public SlaveStepCopyPartitionDistribution(Node node)

Method Details

addPartition

public void addPartition(String slaveServerName,
 String partitionSchemaName,
 int stepCopyNr,
 int partitionNr)

Add a partition number to the distribution for re-use at runtime.

Parameters:

slaveServerName -

partitionSchemaName -

stepCopyNr -

partitionNr -

addPartition

public int addPartition(String slaveServerName,
 String partitionSchemaName,
 int stepCopyNr)

Add a partition number to the distribution if it doesn't already exist.

Parameters:

slaveServerName -

partitionSchemaName -

stepCopyNr -

Returns:

The found or created partition number

getPartition

public int getPartition(String slaveServerName,
 String partitionSchemaName,
 int stepCopyNr)

getXML

public String getXML()

getDistribution

public Map<SlaveStepCopyPartitionDistribution.SlaveStepCopy,Integer> getDistribution()

getOriginalPartitionSchemas

public List<PartitionSchema> getOriginalPartitionSchemas()

Returns:

the originalPartitionSchemas

setOriginalPartitionSchemas

public void setOriginalPartitionSchemas(List<PartitionSchema> originalPartitionSchemas)

Parameters:

originalPartitionSchemas - the originalPartitionSchemas to set

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object