Class TopicPartitionSerializer
java.lang.Object
org.apache.storm.kafka.spout.trident.TopicPartitionSerializer
- 
Field SummaryFields
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionorg.apache.kafka.common.TopicPartitionDeserializes the given map into a TopicPartition.toMap(org.apache.kafka.common.TopicPartition topicPartition) Serializes the given TopicPartition to Map so Trident can serialize it to JSON.
- 
Field Details- 
TOPIC_PARTITION_TOPIC_KEY- See Also:
 
- 
TOPIC_PARTITION_PARTITION_KEY- See Also:
 
 
- 
- 
Constructor Details- 
TopicPartitionSerializerpublic TopicPartitionSerializer()
 
- 
- 
Method Details- 
toMapSerializes the given TopicPartition to Map so Trident can serialize it to JSON.
- 
fromMapDeserializes the given map into a TopicPartition. The map keys are expected to be those produced bytoMap(org.apache.kafka.common.TopicPartition).
 
-