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)
