org.pentaho.di.trans

Class ModPartitioner

java.lang.Object

org.pentaho.di.trans.BasePartitioner

org.pentaho.di.trans.ModPartitioner

All Implemented Interfaces:

Partitioner

public class ModPartitioner
extends BasePartitioner

Constructor Summary

Constructors

Constructor and Description
ModPartitioner()

Method Summary

Methods

Modifier and Type	Method and Description
ModPartitioner	clone() Clone.
String	getDescription() Gets the description.
String	getDialogClassName() Gets the dialog class name.
String	getFieldName()
Partitioner	getInstance() Gets the single instance of Partitioner.
int	getPartition(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row) Gets the partition.
String	getXML() Gets the xml.
void	loadRep(Repository rep, org.pentaho.di.repository.ObjectId id_step) Load rep.
void	loadXML(Node partitioningMethodNode) Load xml.
void	saveRep(Repository rep, org.pentaho.di.repository.ObjectId id_transformation, org.pentaho.di.repository.ObjectId id_step) Saves partitioning properties in the repository for the given step.
void	setFieldName(String fieldName)

Methods inherited from class org.pentaho.di.trans.BasePartitioner

getId, getMeta, getNrPartitions, init, setDescription, setId, setMeta, setNrPartitions

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ModPartitioner

public ModPartitioner()

Method Detail

getInstance

public Partitioner getInstance()

Description copied from interface: Partitioner

Gets the single instance of Partitioner.

Specified by:

getInstance in interface Partitioner

Specified by:

getInstance in class BasePartitioner

Returns:

single instance of Partitioner

clone

public ModPartitioner clone()

Description copied from interface: Partitioner

Clone.

Specified by:

clone in interface Partitioner

Overrides:

clone in class BasePartitioner

Returns:

the partitioner

getDialogClassName

public String getDialogClassName()

Description copied from interface: Partitioner

Gets the dialog class name.

Returns:

the dialog class name

getPartition

public int getPartition(org.pentaho.di.core.row.RowMetaInterface rowMeta,
               Object[] row)
                 throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Partitioner

Gets the partition.

Parameters:

rowMeta - the row meta

row - the r

Returns:

the partition

Throws:

org.pentaho.di.core.exception.KettleException - the kettle exception

getDescription

public String getDescription()

Description copied from interface: Partitioner

Gets the description.

Specified by:

getDescription in interface Partitioner

Overrides:

getDescription in class BasePartitioner

Returns:

the description

getXML

public String getXML()

Description copied from interface: Partitioner

Gets the xml.

Returns:

the xml

loadXML

public void loadXML(Node partitioningMethodNode)
             throws org.pentaho.di.core.exception.KettleXMLException

Description copied from interface: Partitioner

Load xml.

Parameters:

partitioningMethodNode - the partitioning method node

Throws:

org.pentaho.di.core.exception.KettleXMLException - the kettle xml exception

saveRep

public void saveRep(Repository rep,
           org.pentaho.di.repository.ObjectId id_transformation,
           org.pentaho.di.repository.ObjectId id_step)
             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Partitioner

Saves partitioning properties in the repository for the given step.

Parameters:

rep - the repository to save in

id_transformation - the ID of the transformation

id_step - the ID of the step

Throws:

org.pentaho.di.core.exception.KettleException - In case anything goes wrong

loadRep

public void loadRep(Repository rep,
           org.pentaho.di.repository.ObjectId id_step)
             throws org.pentaho.di.core.exception.KettleException

Description copied from interface: Partitioner

Load rep.

Parameters:

rep - the rep

id_step - the id_step

Throws:

org.pentaho.di.core.exception.KettleException - the kettle exception

getFieldName

public String getFieldName()

setFieldName

public void setFieldName(String fieldName)