Class KafkaTridentSpoutBatchMetadata
java.lang.Object
org.apache.storm.kafka.spout.trident.KafkaTridentSpoutBatchMetadata
- All Implemented Interfaces:
- Serializable
Wraps transaction batch information.
- See Also:
- 
Field SummaryFields
- 
Constructor SummaryConstructorsConstructorDescriptionKafkaTridentSpoutBatchMetadata(long firstOffset, long lastOffset, String topologyId) Builds a metadata object.
- 
Method Summary
- 
Field Details- 
FIRST_OFFSET_KEY- See Also:
 
- 
LAST_OFFSET_KEY- See Also:
 
- 
TOPOLOGY_ID_KEY- See Also:
 
 
- 
- 
Constructor Details- 
KafkaTridentSpoutBatchMetadataBuilds a metadata object.- Parameters:
- firstOffset- The first offset for the batch
- lastOffset- The last offset for the batch
 
 
- 
- 
Method Details- 
getFirstOffsetpublic long getFirstOffset()
- 
getLastOffsetpublic long getLastOffset()
- 
getTopologyId
- 
fromMapConstructs a metadata object from a Map in the format produced bytoMap().- Parameters:
- map- The source map
- Returns:
- A new metadata object
 
- 
toMapWrites this metadata object to a Map so Trident can read/write it to Zookeeper.
- 
toString
 
-