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 -
Method Summary
Modifier and TypeMethodDescriptionintcompare(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, waitMethods 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:
comparein interfaceComparator<org.apache.kafka.common.TopicPartition>
-