Versions Compared

Old Version 6

changes.mady.by.user Seth Wiesman

Saved on

compared with

New Version 7

changes.mady.by.user Seth Wiesman

Saved on

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

To improve naming and general understanding we will deprecate the classes MemoryStateBackend, FsStateBackend, and RocksDBStateBackend. The will be replaced with OnHeapStateBackend HashMapStateBackend and EmbeddedRocksDBStateBackend. To be clear, we are not changing any of the runtime data structures or characteristics, these are simply new user-facing api classes. 

...

Code Block
languagejava
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStateBackend(new OnHeapStateBackendHashMapStateBackend())
 
EmbeddedRocksDBStateBackend rocksDB = new EmbeddedRocksDBStateBackend();
rocksDB.setOptionsFactory(/** blah **/);
 
env.setStateBackend(rocksDB);
 
env.getCheckpointConfig().setCheckpointLocation(new JobManagerSnapshot());
env.getCheckpointConfig().setCheckpointLocation(new FileSystemSnapshot("s3://checkpoints"));
env.getCheckpointConfig().setCheckpointLocation("s3://checkpoints");

...