Class PartitionAssignment


  • public class PartitionAssignment
    extends java.lang.Object
    This class represent the assignments of one resource including all of assigned partitions and expected number of partitions.
    • Constructor Detail

      • PartitionAssignment

        public PartitionAssignment​(java.lang.String topic,
                                   int numberOfPartition)
    • Method Detail

      • getPartition

        public Partition getPartition​(int partitionId)
      • addPartition

        public void addPartition​(Partition partition)
      • getAllPartitions

        public java.util.Collection<Partition> getAllPartitions()
      • getExpectedNumberOfPartitions

        public int getExpectedNumberOfPartitions()
      • getAssignedNumberOfPartitions

        public int getAssignedNumberOfPartitions()
      • isMissingAssignedPartitions

        public boolean isMissingAssignedPartitions()
      • getTopic

        public java.lang.String getTopic()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object
      • equals

        public boolean equals​(java.lang.Object obj)
        Overrides:
        equals in class java.lang.Object
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class java.lang.Object