org.apache.storm.kafka.spout.trident

Class KafkaTridentSpoutBatchMetadata

java.lang.Object

org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata

All Implemented Interfaces:

Serializable

public class KafkaTridentSpoutBatchMetadata
extends Object
implements Serializable

Wraps transaction batch information

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static String	FIRST_OFFSET_KEY
static String	LAST_OFFSET_KEY
static String	TOPIC_PARTITION_KEY

Constructor Summary

Constructors

Constructor and Description
KafkaTridentSpoutBatchMetadata(org.apache.kafka.common.TopicPartition topicPartition, org.apache.kafka.clients.consumer.ConsumerRecords<K,V> consumerRecords) Builds a metadata object from a non-empty set of records.
KafkaTridentSpoutBatchMetadata(org.apache.kafka.common.TopicPartition topicPartition, long firstOffset, long lastOffset) Builds a metadata object.

Method Summary

Modifier and Type	Method and Description
static KafkaTridentSpoutBatchMetadata	fromMap(Map<String,Object> map) Constructs a metadata object from a Map in the format produced by toMap().
long	getFirstOffset()
long	getLastOffset()
org.apache.kafka.common.TopicPartition	getTopicPartition()
Map<String,Object>	toMap() Writes this metadata object to a Map so Trident can read/write it to Zookeeper.
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

TOPIC_PARTITION_KEY

public static final String TOPIC_PARTITION_KEY

See Also:

Constant Field Values

FIRST_OFFSET_KEY

public static final String FIRST_OFFSET_KEY

See Also:

Constant Field Values

LAST_OFFSET_KEY

public static final String LAST_OFFSET_KEY

See Also:

Constant Field Values

Constructor Detail

KafkaTridentSpoutBatchMetadata

public KafkaTridentSpoutBatchMetadata(org.apache.kafka.common.TopicPartition topicPartition,
                                      long firstOffset,
                                      long lastOffset)

Builds a metadata object.

Parameters:

topicPartition - The topic partition

firstOffset - The first offset for the batch

lastOffset - The last offset for the batch

KafkaTridentSpoutBatchMetadata

public KafkaTridentSpoutBatchMetadata(org.apache.kafka.common.TopicPartition topicPartition,
                                      org.apache.kafka.clients.consumer.ConsumerRecords<K,V> consumerRecords)

Builds a metadata object from a non-empty set of records.

Parameters:

topicPartition - The topic partition the records belong to.

consumerRecords - The non-empty set of records.

Method Detail

getFirstOffset

public long getFirstOffset()

getLastOffset

public long getLastOffset()

getTopicPartition

public org.apache.kafka.common.TopicPartition getTopicPartition()

fromMap

public static KafkaTridentSpoutBatchMetadata fromMap(Map<String,Object> map)

Constructs a metadata object from a Map in the format produced by toMap().

Parameters:

map - The source map

Returns:

A new metadata object

toMap

public Map<String,Object> toMap()

Writes this metadata object to a Map so Trident can read/write it to Zookeeper.

toString

public final String toString()

Overrides:

toString in class Object