| Constructor and Description |
|---|
TridentKafkaState() |
| Modifier and Type | Method and Description |
|---|---|
void |
beginCommit(Long txid) |
void |
commit(Long txid) |
void |
prepare(Properties options)
Prepare this State.
|
void |
updateState(List<TridentTuple> tuples,
TridentCollector collector)
Write the given tuples to Kafka.
|
TridentKafkaState<K,V> |
withKafkaTopicSelector(KafkaTopicSelector selector) |
TridentKafkaState<K,V> |
withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper<K,V> mapper) |
public TridentKafkaState<K,V> withTridentTupleToKafkaMapper(TridentTupleToKafkaMapper<K,V> mapper)
public TridentKafkaState<K,V> withKafkaTopicSelector(KafkaTopicSelector selector)
public void beginCommit(Long txid)
beginCommit in interface Statepublic void prepare(Properties options)
Prepare this State.
options - The KafkaProducer config.public void updateState(List<TridentTuple> tuples, TridentCollector collector)
Write the given tuples to Kafka.
tuples - The tuples to write.collector - The Trident collector.Copyright © 2021 The Apache Software Foundation. All rights reserved.