[jira] [Created] (FLINK-12585) Align Stream/BatchTableEnvironment with JAVA Table API

[Shang Yuanchun (Jira)]

sunjincheng created FLINK-12585:
-----------------------------------

             Summary: Align Stream/BatchTableEnvironment with JAVA Table API
                 Key: FLINK-12585
                 URL: https://issues.apache.org/jira/browse/FLINK-12585
             Project: Flink
          Issue Type: Sub-task
          Components: API / Python
    Affects Versions: 1.9.0
            Reporter: sunjincheng


Initially we wanted to align with the [FLIP-32|[https://cwiki.apache.org/confluence/display/FLINK/FLIP-32%3A+Restructure+flink-table+for+future+contributions]] plan and Unify the TableEnvironment.  such as:
{code:java}
 TableConfig config = TableConfig.builder()
        .asStreamingExecution()
        // example of providing configuration that was in StreamExecutionEnvironment before
        .watermarkInterval(100)  
        .build();

TableEnvironment tEnv = TableEnvironment.create(config);{code}
So, Current Python Table API as follows:
{code:java}
self.t_config = TableConfig.Builder().as_streaming_execution().set_parallelism(1).build()
self.t_env = TableEnvironment.create(self.t_config){code}
But, due to Java API not have done this improve yet, and the end date of release 1.9 is coming, So, It's better to align the `Stream/BatchTableEnvironment` with JAVA Table API for now. we should follow the current Java style, for example:
{code:java}
val env = StreamExecutionEnvironment.getExecutionEnvironment
env.setStateBackend(getStateBackend)
val tEnv = StreamTableEnvironment.create(env){code}
What to do you think? [~dian.fu] [~WeiZhong] 



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)