Skip to content

Commit

Permalink
[FLINK-11469][docs] Update documentation for `Tuning Checkpoints and …
Browse files Browse the repository at this point in the history
…Large State`

This closes apache#7603.
  • Loading branch information
junsheng.wu authored and StefanRRichter committed Jan 30, 2019
1 parent be0aea7 commit 3abb3de
Showing 1 changed file with 9 additions and 13 deletions.
22 changes: 9 additions & 13 deletions docs/ops/state/large_state_tuning.md
Original file line number Diff line number Diff line change
Expand Up @@ -161,21 +161,17 @@ RocksDBStateBackend.setOptions(new MyOptions());
public class MyOptions implements OptionsFactory {

@Override
public DBOptions createDBOptions() {
return new DBOptions()
.setIncreaseParallelism(4)
.setUseFsync(false)
.setDisableDataSync(true);
public DBOptions createDBOptions(DBOptions currentOptions) {
return currentOptions.setIncreaseParallelism(4)
.setUseFsync(false);
}

@Override
public ColumnFamilyOptions createColumnOptions() {

return new ColumnFamilyOptions()
.setTableFormatConfig(
new BlockBasedTableConfig()
.setBlockCacheSize(256 * 1024 * 1024) // 256 MB
.setBlockSize(128 * 1024)); // 128 KB
public ColumnFamilyOptions createColumnOptions(ColumnFamilyOptions currentOptions) {
return currentOptions.setTableFormatConfig(
new BlockBasedTableConfig()
.setBlockCacheSize(256 * 1024 * 1024) // 256 MB
.setBlockSize(128 * 1024)); // 128 KB
}
}
{% endhighlight %}
Expand Down

0 comments on commit 3abb3de

Please sign in to comment.