[
https://issues.apache.org/jira/browse/FLINK-11067?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16728590#comment-16728590
]
sunjincheng commented on FLINK-11067:
-------------------------------------
Hi [~twalthr], Thank you for improving the interface definition!:)
I think `flink-tabe-api-base` also need add `BaseBatchTableEnvironment` and
`BaseStreamTableEnvironment` for Java and scala shared methods, such as
`registerTableSink` etc. So in this way we have added several base classes, but
solved the compatibility problem.
At present, we still have a problem with stream and batch unification, which
means that users do not need to know whether it is batchEnv or StreamEnv. This
change will lead to compatibility issues, which can be discussed and resolved
in another JIRA.
What do you think?
> Port TableEnvironments to Java
> ------------------------------
>
> Key: FLINK-11067
> URL: https://issues.apache.org/jira/browse/FLINK-11067
> Project: Flink
> Issue Type: Sub-task
> Components: Table API & SQL
> Reporter: Timo Walther
> Assignee: Dawid Wysakowicz
> Priority: Major
>
> This task includes porting {{TableEnvironment}}, {{StreamTableEnvironment}},
> {{BatchTableEnvironment}} to Java. API-breaking changes need to be avoided
> and discussed. Some refactoring and clean up might be necessary.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)