Package org.apache.storm.kafka.trident
Class TridentKafkaState<K,V>
java.lang.Object
org.apache.storm.kafka.trident.TridentKafkaState<K,V>
- All Implemented Interfaces:
State
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
beginCommit
(Long txid) void
void
prepare
(Properties options) Prepare this State.void
updateState
(List<TridentTuple> tuples, TridentCollector collector) Write the given tuples to Kafka.withKafkaTopicSelector
(KafkaTopicSelector selector)
-
Constructor Details
-
TridentKafkaState
public TridentKafkaState()
-
-
Method Details
-
withTridentTupleToKafkaMapper
-
withKafkaTopicSelector
-
beginCommit
- Specified by:
beginCommit
in interfaceState
-
commit
-
prepare
Prepare this State.- Parameters:
options
- The KafkaProducer config.
-
updateState
Write the given tuples to Kafka.- Parameters:
tuples
- The tuples to write.collector
- The Trident collector.
-