Package org.pentaho.di.trans.step

Class StepPartitioningMeta

java.lang.Object
org.pentaho.di.trans.step.StepPartitioningMeta
All Implemented Interfaces:
Cloneable, org.pentaho.di.core.xml.XMLInterface
public class StepPartitioningMeta extends Object implements org.pentaho.di.core.xml.XMLInterface, Cloneable

  • Field Details

    • PARTITIONING_METHOD_NONE

      public static final int PARTITIONING_METHOD_NONE
      See Also:

    • PARTITIONING_METHOD_MIRROR

      public static final int PARTITIONING_METHOD_MIRROR
      See Also:

    • PARTITIONING_METHOD_SPECIAL

      public static final int PARTITIONING_METHOD_SPECIAL
      See Also:

    • methodCodes

      public static final String[] methodCodes

    • methodDescriptions

      public static final String[] methodDescriptions

  • Constructor Details

    • StepPartitioningMeta

      public StepPartitioningMeta()

    • StepPartitioningMeta

      public StepPartitioningMeta(String method, PartitionSchema partitionSchema) throws org.pentaho.di.core.exception.KettlePluginException
      Parameters:
      method -
      partitionSchema -
      Throws:
      org.pentaho.di.core.exception.KettlePluginException

    • StepPartitioningMeta

      public StepPartitioningMeta(Node partitioningMethodNode) throws org.pentaho.di.core.exception.KettleException
      Throws:
      org.pentaho.di.core.exception.KettleException

  • Method Details

    • clone

      public StepPartitioningMeta clone()
      Overrides:
      clone in class Object

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object
      Returns:
      true if the partition schema names are the same.

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • getMethodType

      public int getMethodType()
      Returns:
      the partitioningMethod

    • setMethod

      public void setMethod(String method) throws org.pentaho.di.core.exception.KettlePluginException
      Parameters:
      method - the partitioning method to set
      Throws:
      org.pentaho.di.core.exception.KettlePluginException

    • getXML

      public String getXML()
      Specified by:
      getXML in interface org.pentaho.di.core.xml.XMLInterface

    • getMethodCode

      public String getMethodCode()

    • getMethodDescription

      public String getMethodDescription()

    • getMethod

      public String getMethod()

    • getMethod

      public static final String getMethod(String name)

    • getMethodType

      public static final int getMethodType(String description)

    • isPartitioned

      public boolean isPartitioned()

    • setPartitionSchemaName

      public void setPartitionSchemaName(String partitionSchemaName)

    • getPartitionSchema

      public PartitionSchema getPartitionSchema()
      Returns:
      the partitionSchema

    • setPartitionSchema

      public void setPartitionSchema(PartitionSchema partitionSchema)
      Parameters:
      partitionSchema - the partitionSchema to set

    • setPartitionSchemaAfterLoading

      public void setPartitionSchemaAfterLoading(List<PartitionSchema> partitionSchemas) throws org.pentaho.di.core.exception.KettleException
      Set the partitioning schema after loading from XML or repository
      Parameters:
      partitionSchemas - the list of partitioning schemas
      Throws:
      org.pentaho.di.core.exception.KettleException

    • createPartitioner

      public void createPartitioner(String method) throws org.pentaho.di.core.exception.KettlePluginException
      Throws:
      org.pentaho.di.core.exception.KettlePluginException

    • isMethodMirror

      public boolean isMethodMirror()

    • getPartition

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

    • getPartitioner

      public Partitioner getPartitioner()

    • setPartitioner

      public void setPartitioner(Partitioner partitioner)

    • hasChanged

      public boolean hasChanged()

    • hasChanged

      public void hasChanged(boolean hasChanged)

    • setMethodType

      public void setMethodType(int methodType)