THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
/**
* An interface that extends user facing {@link KeyedStateBackend} with internal system specific features.
*/
public interface InternalKeyedStateBackend<K> extends
KeyedStateBackend<K>,
SnapshotStrategy<SnapshotResult<KeyedStateHandle>>,
Closeable,
CheckpointListener {
KeyGroupRange getKeyGroupRange();
boolean supportsAsynchronousSnapshots();
// TODO remove this once heap-based timers are working with RocksDB incremental snapshots!
boolean requiresLegacySynchronousTimerSnapshots();
} |
Then the StateBackend
class would create this new interface instead of the AbstractKeyedStateBackend
:
...