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 SummaryFields
- 
Method SummaryModifier and TypeMethodDescriptionintcompare(org.apache.kafka.common.TopicPartition o1, org.apache.kafka.common.TopicPartition o2) Methods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface java.util.Comparatorequals, reversed, thenComparing, thenComparing, thenComparing, thenComparingDouble, thenComparingInt, thenComparingLong
- 
Field Details- 
INSTANCE
 
- 
- 
Method Details- 
comparepublic int compare(org.apache.kafka.common.TopicPartition o1, org.apache.kafka.common.TopicPartition o2) - Specified by:
- comparein interface- Comparator<org.apache.kafka.common.TopicPartition>
 
 
-