Package org.pentaho.di.trans
Class ModPartitioner
java.lang.Object
org.pentaho.di.trans.BasePartitioner
org.pentaho.di.trans.ModPartitioner
- All Implemented Interfaces:
Partitioner
-
Field Summary
FieldsFields inherited from class org.pentaho.di.trans.BasePartitioner
description, id, meta, nrPartitions -
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionclone()Clone.Gets the description.Gets the dialog class name.Gets the single instance of Partitioner.intgetPartition(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row) Gets the partition.getXML()Gets the xml.voidloadRep(Repository rep, org.pentaho.di.repository.ObjectId id_step) Load rep.voidLoad xml.voidsaveRep(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.voidsetFieldName(String fieldName) Methods inherited from class org.pentaho.di.trans.BasePartitioner
getId, getMeta, getNrPartitions, init, setDescription, setId, setMeta, setNrPartitions
-
Field Details
-
partitionColumnIndex
protected int partitionColumnIndex
-
-
Constructor Details
-
ModPartitioner
public ModPartitioner()
-
-
Method Details
-
getInstance
Description copied from interface:PartitionerGets the single instance of Partitioner.- Specified by:
getInstancein interfacePartitioner- Specified by:
getInstancein classBasePartitioner- Returns:
- single instance of Partitioner
-
clone
Description copied from interface:PartitionerClone.- Specified by:
clonein interfacePartitioner- Overrides:
clonein classBasePartitioner- Returns:
- the partitioner
-
getDialogClassName
Description copied from interface:PartitionerGets 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:PartitionerGets the partition.- Parameters:
rowMeta- the row metarow- the r- Returns:
- the partition
- Throws:
org.pentaho.di.core.exception.KettleException- the kettle exception
-
getDescription
Description copied from interface:PartitionerGets the description.- Specified by:
getDescriptionin interfacePartitioner- Overrides:
getDescriptionin classBasePartitioner- Returns:
- the description
-
getXML
Description copied from interface:PartitionerGets the xml.- Returns:
- the xml
-
loadXML
public void loadXML(Node partitioningMethodNode) throws org.pentaho.di.core.exception.KettleXMLException Description copied from interface:PartitionerLoad 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:PartitionerSaves partitioning properties in the repository for the given step.- Parameters:
rep- the repository to save inid_transformation- the ID of the transformationid_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:PartitionerLoad rep.- Parameters:
rep- the repid_step- the id_step- Throws:
org.pentaho.di.core.exception.KettleException- the kettle exception
-
getFieldName
-
setFieldName
-