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

Fields

Modifier and Type	Field and Description
static String[]	methodCodes
static String[]	methodDescriptions
static int	PARTITIONING_METHOD_MIRROR
static int	PARTITIONING_METHOD_NONE
static int	PARTITIONING_METHOD_SPECIAL

Constructor Summary

Constructors

Constructor and Description
StepPartitioningMeta()
StepPartitioningMeta(Node partitioningMethodNode)
StepPartitioningMeta(String method, PartitionSchema partitionSchema)

Method Summary

Modifier and Type	Method and Description
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()
boolean	hasChanged()
void	hasChanged(boolean hasChanged)
int	hashCode()
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

finalize, getClass, 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.

hashCode

public int hashCode()

Overrides:

hashCode in class Object

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()

Specified by:

getXML in interface XMLInterface

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)