Package org.apache.flink.state.changelog
Interface ChangelogState
-
- All Known Implementing Classes:
ChangelogKeyGroupedPriorityQueue
@Internal public interface ChangelogState
State used byChangelogKeyedStateBackend. Allows replaying recorded changes on recovery usingStateChangeApplier
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description StateChangeAppliergetChangeApplier(ChangelogApplierFactory factory)voidresetWritingMetaFlag()Enable logging meta data before next writes.<IS> voidsetDelegatedState(IS state)
-
-
-
Method Detail
-
getChangeApplier
StateChangeApplier getChangeApplier(ChangelogApplierFactory factory)
-
setDelegatedState
<IS> void setDelegatedState(IS state)
-
resetWritingMetaFlag
void resetWritingMetaFlag()
Enable logging meta data before next writes.
-
-