Package org.apache.storm.kafka.spout.trident

Class TopicPartitionSerializer

java.lang.Object

org.apache.storm.kafka.spout.trident.TopicPartitionSerializer

public class TopicPartitionSerializer
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final String	TOPIC_PARTITION_PARTITION_KEY
static final String	TOPIC_PARTITION_TOPIC_KEY

Constructor Summary

Constructors

Constructor	Description
TopicPartitionSerializer()

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.common.TopicPartition	fromMap(Map<String,Object> map)	Deserializes the given map into a TopicPartition.
Map<String,Object>	toMap(org.apache.kafka.common.TopicPartition topicPartition)	Serializes the given TopicPartition to Map so Trident can serialize it to JSON.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

TOPIC_PARTITION_TOPIC_KEY

public static final String TOPIC_PARTITION_TOPIC_KEY

See Also:

• Constant Field Values

TOPIC_PARTITION_PARTITION_KEY

public static final String TOPIC_PARTITION_PARTITION_KEY

See Also:

• Constant Field Values

Constructor Details

TopicPartitionSerializer

public TopicPartitionSerializer()

Method Details

toMap

public Map<String,Object> toMap(org.apache.kafka.common.TopicPartition topicPartition)

Serializes the given TopicPartition to Map so Trident can serialize it to JSON.

fromMap

public org.apache.kafka.common.TopicPartition fromMap(Map<String,Object> map)

Deserializes the given map into a TopicPartition. The map keys are expected to be those produced by toMap(org.apache.kafka.common.TopicPartition).