[jira] [Created] (FLINK-2579) StreamExecutionEnvironment & ExecutionEnvironment do not share interface but have a lot in common

[Shang Yuanchun (Jira)]

Arnaud Linz created FLINK-2579:
----------------------------------

             Summary: StreamExecutionEnvironment & ExecutionEnvironment do not share interface but have a lot in common
                 Key: FLINK-2579
                 URL: https://issues.apache.org/jira/browse/FLINK-2579
             Project: Flink
          Issue Type: Improvement
          Components: Core
            Reporter: Arnaud Linz
            Priority: Minor


Both classes org.apache.flink.streaming.api.environment.StreamExecutionEnvironment and org.apache.flink.api.java.ExecutionEnvironment have a lot in common (same methods for kryo registration, fromCollection, etc) but are not related by a java contract.

That leads to annoying differences, for instance : StreamExecutionEnvironment.setParallelism() returns 'this' where as ExecutionEnvironment.setParallelism() has not return value.

They have specificities, but maybe they should both implement a common Interface to make sure that the common signatures are coherent?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)