Class KafkaTridentSpoutTopicPartition
java.lang.Object
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutTopicPartition
- All Implemented Interfaces:
- Serializable,- ISpoutPartition
public class KafkaTridentSpoutTopicPartition
extends Object
implements ISpoutPartition, Serializable
ISpoutPartition that wraps TopicPartition information.- See Also:
- 
Constructor SummaryConstructorsConstructorDescriptionKafkaTridentSpoutTopicPartition(String topic, int partition) KafkaTridentSpoutTopicPartition(org.apache.kafka.common.TopicPartition topicPartition) 
- 
Method Summary
- 
Constructor Details- 
KafkaTridentSpoutTopicPartition
- 
KafkaTridentSpoutTopicPartitionpublic KafkaTridentSpoutTopicPartition(org.apache.kafka.common.TopicPartition topicPartition) 
 
- 
- 
Method Details- 
getTopicPartitionpublic org.apache.kafka.common.TopicPartition getTopicPartition()
- 
getIdDescription copied from interface:ISpoutPartitionThis is used as a Zookeeper node path for storing metadata.- Specified by:
- getIdin interface- ISpoutPartition
 
- 
equals
- 
hashCodepublic int hashCode()
- 
toString
 
-