[jira] [Created] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-14835) Make `org.apache.flink.configuration.Configuration` support method chaining

Shang Yuanchun (Jira)
Victor Wong created FLINK-14835:
-----------------------------------

             Summary: 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


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



--
This message was sent by Atlassian Jira
(v8.3.4#803005)