[ https://issues.apache.org/jira/browse/FLINK-14835?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Victor Wong updated FLINK-14835: -------------------------------- Description: To make the following code examples work in production, which is very handy for users to set a couple of configurations. {code:java} // instantiate table environment TableEnvironment tEnv = ...tEnv.getConfig() // access high-level configuration .getConfiguration() // set low-level key-value options .setString("table.exec.mini-batch.enabled", "true") // enable mini-batch optimization .setString("table.exec.mini-batch.allow-latency", "5 s") // use 5 seconds to buffer input records .setString("table.exec.mini-batch.size", "5000"); // the maximum number of records can be buffered by each aggregate operator task {code} was: To make the following code examples work in production, which is very handy for users to set a couple of configurations. // instantiate table environmentTableEnvironment tEnv = ...tEnv.getConfig() // access high-level configuration .getConfiguration() // set low-level key-value options .setString("table.exec.mini-batch.enabled", "true") // enable mini-batch optimization .setString("table.exec.mini-batch.allow-latency", "5 s") // use 5 seconds to buffer input records .setString("table.exec.mini-batch.size", "5000"); // the maximum number of records can be buffered by each aggregate operator task > Make `org.apache.flink.configuration.Configuration` support method chaining > --------------------------------------------------------------------------- > > Key: FLINK-14835 > URL: https://issues.apache.org/jira/browse/FLINK-14835 > Project: Flink > Issue Type: Improvement > Components: Runtime / Configuration > Affects Versions: 1.9.1 > Reporter: Victor Wong > Priority: Major > > To make the following code examples work in production, which is very handy > for users to set a couple of configurations. > > {code:java} > // instantiate table environment > TableEnvironment tEnv = ...tEnv.getConfig() // access high-level > configuration > .getConfiguration() // set low-level key-value options > .setString("table.exec.mini-batch.enabled", "true") // enable mini-batch > optimization > .setString("table.exec.mini-batch.allow-latency", "5 s") // use 5 seconds > to buffer input records > .setString("table.exec.mini-batch.size", "5000"); // the maximum number of > records can be buffered by each aggregate operator task > {code} -- This message was sent by Atlassian Jira (v8.3.4#803005)