StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
env.setStateBackend(new HashMapStateBackend())
 
EmbeddedRocksDBStateBackend rocksDB = new EmbeddedRocksDBStateBackend();
rocksDB.setOptionsFactory(/** blah **/);
 
env.setStateBackend(rocksDB);
 env.setDefaultSavepointDirectory("s3://savepoint");

env.getCheckpointConfig().setCheckpointLocationsetCheckpointStorage(new JobManagerSnapshot());
env.getCheckpointConfig().setCheckpointLocationsetCheckpointStorage(new FileSystemSnapshot("s3://checkpoints"));
env.getCheckpointConfig().setCheckpointLocationsetCheckpointStorage("s3://checkpoints");