Class BasePartitioner

  • All Implemented Interfaces:
    Partitioner
    Direct Known Subclasses:
    ModPartitioner

    public abstract class BasePartitioner
    extends Object
    implements Partitioner
    Implements common functionality needed by partitioner plugins.
    • Constructor Detail

      • BasePartitioner

        public BasePartitioner()
        Instantiates a new base partitioner.
    • Method Detail

      • getNrPartitions

        public int getNrPartitions()
        Gets the nr partitions.
        Returns:
        the nr partitions
      • setNrPartitions

        public void setNrPartitions​(int nrPartitions)
        Sets the nr partitions.
        Parameters:
        nrPartitions - the new nr partitions
      • init

        public void init​(org.pentaho.di.core.row.RowMetaInterface rowMeta)
                  throws org.pentaho.di.core.exception.KettleException
        Inits the.
        Parameters:
        rowMeta - the row meta
        Throws:
        org.pentaho.di.core.exception.KettleException - the kettle exception
      • getInstance

        public abstract Partitioner getInstance()
        Description copied from interface: Partitioner
        Gets the single instance of Partitioner.
        Specified by:
        getInstance in interface Partitioner
        Returns:
        single instance of Partitioner
      • setDescription

        public void setDescription​(String description)
        Description copied from interface: Partitioner
        Sets the description.
        Specified by:
        setDescription in interface Partitioner
        Parameters:
        description - the new description
      • setId

        public void setId​(String id)
        Description copied from interface: Partitioner
        Sets the id.
        Specified by:
        setId in interface Partitioner
        Parameters:
        id - the new id