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
-
Method Summary
Modifier and TypeMethodDescriptionint
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
-
-
Method Details
-
compare
public int compare(org.apache.kafka.common.TopicPartition o1, org.apache.kafka.common.TopicPartition o2) - Specified by:
compare
in interfaceComparator<org.apache.kafka.common.TopicPartition>
-