Hi Paul, The *.scala.StreamTableEnvironment is for Scala programs, the *.java.StreamTableEnvironment for Java programs and the third is the common basis of the Scala and Java environment. TableEnvironment.getTableEnvironment automatically creates the appropriate TableEnvironment based on the provided ExecuctionEnvironment.
The Table API and SQL are designed to be unified APIs for batch and streaming and we aim to support the same queries on batch and streaming tables. Best, Fabian 2017-10-29 15:39 GMT+01:00 PaulWu <zwu....@gmail.com>: > Sorry for my rant...fairly new. Felt lost. The one (StreamTableEnvironment) > from java needs to use the constructor: > StreamTableEnvironment(StreamExecutionEnvironment execEnv, TableConfig > config) . > > Now it works. Thanks. Still confused...why > > BatchTableEnvironment tEnv = TableEnvironment.getTableEnvironment(env); > > works? Even it could have some same compiling error sometimes. > > > > > -- > Sent from: http://apache-flink-user-mailing-list-archive.2336050. > n4.nabble.com/ >
