public interface State
There’s 3 different kinds of state:
repeat transactional is idempotent for transactional spouts opaque transactional is idempotent for opaque or transactional spouts
Trident should log warnings when state is idempotent but updates will not be idempotent because of spout
Modifier and Type | Method and Description |
---|---|
void |
beginCommit(Long txid) |
void |
commit(Long txid) |
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.