Modifier and Type | Class and Description |
---|---|
static class |
RocketMqState.Options |
Modifier | Constructor and Description |
---|---|
protected |
RocketMqState(Map<String,Object> map,
RocketMqState.Options options) |
Modifier and Type | Method and Description |
---|---|
void |
beginCommit(Long txid) |
void |
commit(Long txid) |
protected void |
prepare() |
void |
updateState(List<TridentTuple> tuples,
TridentCollector collector)
Update the RocketMQ state.
|
protected RocketMqState(Map<String,Object> map, RocketMqState.Options options)
protected void prepare()
public void beginCommit(Long txid)
beginCommit
in interface State
public void updateState(List<TridentTuple> tuples, TridentCollector collector)
Update the RocketMQ state.
tuples
- trident tuplescollector
- trident collectorCopyright © 2022 The Apache Software Foundation. All rights reserved.