org.pentaho.di.trans.step
Class StepPartitioningMeta

java.lang.Object
  org.pentaho.di.trans.step.StepPartitioningMeta

All Implemented Interfaces:

Cloneable, XMLInterface

public class StepPartitioningMeta
extends Object
implements XMLInterface, Cloneable

Field Summary

static String[]	methodCodes
static String[]	methodDescriptions
static int	PARTITIONING_METHOD_MIRROR
static int	PARTITIONING_METHOD_NONE
static int	PARTITIONING_METHOD_SPECIAL

Constructor Summary

StepPartitioningMeta()

StepPartitioningMeta(Node partitioningMethodNode)

StepPartitioningMeta(String method, PartitionSchema partitionSchema)

Method Summary

StepPartitioningMeta	clone()
void	createPartitioner(String method)
boolean	equals(Object obj)
String	getMethod()
static String	getMethod(String name)
String	getMethodCode()
String	getMethodDescription()
int	getMethodType()
static int	getMethodType(String description)
int	getPartition(RowMetaInterface rowMeta, Object[] row)
Partitioner	getPartitioner()
PartitionSchema	getPartitionSchema()
String	getXML() Describes the Object implementing this interface as XML
boolean	hasChanged()
void	hasChanged(boolean hasChanged)
boolean	isMethodMirror()
boolean	isPartitioned()
void	setMethod(String method)
void	setMethodType(int methodType)
void	setPartitioner(Partitioner partitioner)
void	setPartitionSchema(PartitionSchema partitionSchema)
void	setPartitionSchemaAfterLoading(List<PartitionSchema> partitionSchemas) Set the partitioning schema after loading from XML or repository
void	setPartitionSchemaName(String partitionSchemaName)
String	toString()

Methods inherited from class java.lang.Object

getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

PARTITIONING_METHOD_NONE

public static final int PARTITIONING_METHOD_NONE

See Also:

Constant Field Values

PARTITIONING_METHOD_MIRROR

public static final int PARTITIONING_METHOD_MIRROR

See Also:

Constant Field Values

PARTITIONING_METHOD_SPECIAL

public static final int PARTITIONING_METHOD_SPECIAL

See Also:

Constant Field Values

methodCodes

public static final String[] methodCodes

methodDescriptions

public static final String[] methodDescriptions

Constructor Detail

StepPartitioningMeta

public StepPartitioningMeta()

StepPartitioningMeta

public StepPartitioningMeta(String method,
                            PartitionSchema partitionSchema)
                     throws KettlePluginException

Parameters:

method -

partitionSchema -

Throws:

KettlePluginException

StepPartitioningMeta

public StepPartitioningMeta(Node partitioningMethodNode)
                     throws KettleException

Throws:

KettleException

Method Detail

clone

public StepPartitioningMeta clone()

Overrides:

clone in class Object

equals

public boolean equals(Object obj)

Overrides:

equals in class Object

Returns:

true if the partition schema names are the same.

toString

public String toString()

Overrides:

toString in class Object

getMethodType

public int getMethodType()

Returns:

the partitioningMethod

setMethod

public void setMethod(String method)
               throws KettlePluginException

Parameters:

method - the partitioning method to set

Throws:

KettlePluginException

getXML

public String getXML()

Description copied from interface: XMLInterface

Describes the Object implementing this interface as XML

Specified by:

getXML in interface XMLInterface

Returns:

the XML string for this object

getMethodCode

public String getMethodCode()

getMethodDescription

public String getMethodDescription()

getMethod

public String getMethod()

getMethod

public static final String getMethod(String name)

getMethodType

public static final int getMethodType(String description)

isPartitioned

public boolean isPartitioned()

setPartitionSchemaName

public void setPartitionSchemaName(String partitionSchemaName)

getPartitionSchema

public PartitionSchema getPartitionSchema()

Returns:

the partitionSchema

setPartitionSchema

public void setPartitionSchema(PartitionSchema partitionSchema)

Parameters:

partitionSchema - the partitionSchema to set

setPartitionSchemaAfterLoading

public void setPartitionSchemaAfterLoading(List<PartitionSchema> partitionSchemas)
                                    throws KettleException

Set the partitioning schema after loading from XML or repository

Parameters:

partitionSchemas - the list of partitioning schemas

Throws:

KettleException

createPartitioner

public void createPartitioner(String method)
                       throws KettlePluginException

Throws:

KettlePluginException

isMethodMirror

public boolean isMethodMirror()

getPartition

public int getPartition(RowMetaInterface rowMeta,
                        Object[] row)
                 throws KettleException

Throws:

KettleException

getPartitioner

public Partitioner getPartitioner()

setPartitioner

public void setPartitioner(Partitioner partitioner)

hasChanged

public boolean hasChanged()

hasChanged

public void hasChanged(boolean hasChanged)

setMethodType

public void setMethodType(int methodType)