Module datarush.commons
Package com.pervasive.datarush.cal

Class PartitionInstanceInfo

java.lang.Object
com.pervasive.datarush.cal.PartitionInstanceInfo
All Implemented Interfaces:
Serializable
public final class PartitionInstanceInfo extends Object implements Serializable
Information pertaining to an instance of a partitioning operation. Captures the total partition count and the identifier of the current partition (holder of and object of this class). The partition identifier is a zero-based, one-up number used to uniquely identify each partition within a partition set.
See Also:

  • Field Details

    • MASTER

      public static final PartitionInstanceInfo MASTER
      Partition info for a master node. Partition id is always zero and partitionCount is always one because only workers are parallelizable.

  • Constructor Details

    • PartitionInstanceInfo

      public PartitionInstanceInfo(NodeAllocationState.AssignmentState assignment, int partitionCount)
      Construct with given count and ID.
      Parameters:
      partitionCount - total partition count
      partitionID - current partition ID

  • Method Details

    • getPartitionCount

      public int getPartitionCount()
      Get the partition count.
      Returns:
      partition count

    • getAssignment

      public NodeAllocationState.AssignmentState getAssignment()
      Returns the assignment
      Returns:
      the assignment

    • getPartitionID

      public int getPartitionID()
      Get the partition ID.
      Returns:
      partition ID

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object o)
      Overrides:
      equals in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object