THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
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 | ||
---|---|---|
| ||
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"); |
...