Package org.apache.storm.kafka.spout

# Class TopicPartitionComparator

java.lang.Object
org.apache.storm.kafka.spout.TopicPartitionComparator

All Implemented Interfaces:
  `Comparator<org.apache.kafka.common.TopicPartition>`

public class TopicPartitionComparator extends Object implements Comparator<org.apache.kafka.common.TopicPartition>
Singleton comparator of TopicPartitions. Topics have precedence over partitions. Topics are compared through String.compare and partitions are compared numerically.

Use INSTANCE for all sorting.

- ## Field Summary

  Fields
  Modifier and Type
  Field
  Description
  `static final TopicPartitionComparator`
  `INSTANCE`

- ## Method Summary

  Modifier and Type
  Method
  Description
  `int`
  `compare(org.apache.kafka.common.TopicPartition o1, org.apache.kafka.common.TopicPartition o2)`

  ### Methods inherited from class java.lang.Object

  `clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait`

  ### Methods inherited from interface java.util.Comparator

  `equals, reversed, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong`

- ## Field Details

  - ### INSTANCE

    public static final TopicPartitionComparator INSTANCE

- ## Method Details

  - ### compare

    public int compare(org.apache.kafka.common.TopicPartition o1, org.apache.kafka.common.TopicPartition o2)
    Specified by:
      `compare` in interface `Comparator<org.apache.kafka.common.TopicPartition>`