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 Description static String
FIRST_OFFSET_KEY
static String
LAST_OFFSET_KEY
static String
TOPOLOGY_ID_KEY
-
Constructor Summary
Constructors Constructor Description KafkaTridentSpoutBatchMetadata(long firstOffset, long lastOffset, String topologyId)
Builds a metadata object.
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static KafkaTridentSpoutBatchMetadata
fromMap(Map<String,Object> map)
Constructs a metadata object from a Map in the format produced bytoMap()
.long
getFirstOffset()
long
getLastOffset()
String
getTopologyId()
Map<String,Object>
toMap()
Writes this metadata object to a Map so Trident can read/write it to Zookeeper.String
toString()
-
-
-
Field Detail
-
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
-
TOPOLOGY_ID_KEY
public static final String TOPOLOGY_ID_KEY
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
KafkaTridentSpoutBatchMetadata
public KafkaTridentSpoutBatchMetadata(long firstOffset, long lastOffset, String topologyId)
Builds a metadata object.- Parameters:
firstOffset
- The first offset for the batchlastOffset
- The last offset for the batch
-
-
Method Detail
-
getFirstOffset
public long getFirstOffset()
-
getLastOffset
public long getLastOffset()
-
getTopologyId
public String getTopologyId()
-
fromMap
public static KafkaTridentSpoutBatchMetadata fromMap(Map<String,Object> map)
Constructs a metadata object from a Map in the format produced bytoMap()
.- 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.
-
-