public class ModPartitioner extends BasePartitioner
Constructor and Description |
---|
ModPartitioner() |
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) |
getId, getMeta, getNrPartitions, init, setDescription, setId, setMeta, setNrPartitions
public Partitioner getInstance()
Partitioner
getInstance
in interface Partitioner
getInstance
in class BasePartitioner
public ModPartitioner clone()
Partitioner
clone
in interface Partitioner
clone
in class BasePartitioner
public String getDialogClassName()
Partitioner
public int getPartition(org.pentaho.di.core.row.RowMetaInterface rowMeta, Object[] row) throws org.pentaho.di.core.exception.KettleException
Partitioner
rowMeta
- the row metarow
- the rorg.pentaho.di.core.exception.KettleException
- the kettle exceptionpublic String getDescription()
Partitioner
getDescription
in interface Partitioner
getDescription
in class BasePartitioner
public String getXML()
Partitioner
public void loadXML(Node partitioningMethodNode) throws org.pentaho.di.core.exception.KettleXMLException
Partitioner
partitioningMethodNode
- the partitioning method nodeorg.pentaho.di.core.exception.KettleXMLException
- the kettle xml exceptionpublic 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
Partitioner
rep
- the repository to save inid_transformation
- the ID of the transformationid_step
- the ID of the steporg.pentaho.di.core.exception.KettleDatabaseException
- In case anything goes wrongorg.pentaho.di.core.exception.KettleException
public void loadRep(Repository rep, org.pentaho.di.repository.ObjectId id_step) throws org.pentaho.di.core.exception.KettleException
Partitioner
rep
- the repid_step
- the id_steporg.pentaho.di.core.exception.KettleException
- the kettle exceptionpublic String getFieldName()
public void setFieldName(String fieldName)