[FLINK-3811] Refactor ExecutionEnvironment in TableEnvironment

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Fix Version/s: 1.1.0
• Component/s: Table SQL / API
• Assignee: Fabian Hueske
• Reporter: Fabian Hueske
• Created: 25/Apr/16 19:38
• Updated: 26/Apr/16 10:34
• Resolved: 26/Apr/16 10:34

Description

Currently, the Scala BatchTableEnvironment has a reference to a Scala ExecutionEnvironment and the Java BatchTableEnvironment uses the Java ExecutionEnvironment. The same applies to their streaming counterparts.
This requires special implementations for Java / Scala for instance to create new data sources.

I propose to refactor the TableEnvironments such that only the Java execution environments for batch and streaming are used.