Jeff Zhang created FLINK-10873:
----------------------------------
Summary: Remove tableEnv in DataSetConversions#toTable and
DataStreamConversions#toTable
Key: FLINK-10873
URL: https://issues.apache.org/jira/browse/FLINK-10873
Project: Flink
Issue Type: Improvement
Reporter: Jeff Zhang
What I would like to achieve is to change the following code
{code}
val table = data.flatMap(line=>line.split("\\s"))
.map(w => (w, 1))
.toTable(tEnv, 'word, 'count)
{code}
to this
{code}
val table = data.flatMap(line=>line.split("\\s"))
.map(w => (w, 1))
.toTable('word, 'count)
{code}
The only change is that tableEnv is removed in method toTable. I think the
second piece of code is more readable. We can create TableEnvironment based on
the ExecutionEnvironment of DataSet/DataStream rather than asking user to pass
it explicitly.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
