Package 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
-
-
Field Summary
Fields Modifier and Type Field Description protected int
partitionColumnIndex
-
Fields inherited from class org.pentaho.di.trans.BasePartitioner
description, id, meta, nrPartitions
-
-
Constructor Summary
Constructors Constructor Description ModPartitioner()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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
-
-
-
-
Method Detail
-
getInstance
public Partitioner getInstance()
Description copied from interface:Partitioner
Gets the single instance of Partitioner.- Specified by:
getInstance
in interfacePartitioner
- Specified by:
getInstance
in classBasePartitioner
- Returns:
- single instance of Partitioner
-
clone
public ModPartitioner clone()
Description copied from interface:Partitioner
Clone.- Specified by:
clone
in interfacePartitioner
- Overrides:
clone
in classBasePartitioner
- 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 metarow
- 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 interfacePartitioner
- Overrides:
getDescription
in classBasePartitioner
- 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 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:Partitioner
Load rep.- Parameters:
rep
- the repid_step
- the id_step- Throws:
org.pentaho.di.core.exception.KettleException
- the kettle exception
-
getFieldName
public String getFieldName()
-
setFieldName
public void setFieldName(String fieldName)
-
-