You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "Jeff Zhang (JIRA)" <ji...@apache.org> on 2018/11/14 07:06:00 UTC
[jira] [Created] (FLINK-10873) Remove tableEnv in
DataSetConversions#toTable and DataStreamConversions#toTable
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)