Usually, the problem occurs when users import the wrong classes. The
current class naming is a bit confusing as there are 3
StreamTableEnvironment classes. You need to choose the one that matches
your programming language. E.g.
org.apache.flink.table.api.java.StreamTableEnvironment.
Regards,
Timo
Am 02.11.18 um 04:32 schrieb Michael Latta:
Thanks, I will check it out.
Michael
Sent from my iPad
On Nov 1, 2018, at 8:22 PM, Hequn Cheng <chenghe...@gmail.com
<mailto:chenghe...@gmail.com>> wrote:
Hi Michael,
There are some test cases in Flink git, such as[1] which I think may
help you.
Best, Hequn
[1]
https://github.com/apache/flink/blob/master/flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/stream/sql/JavaSqlITCase.java
On Fri, Nov 2, 2018 at 7:46 AM TechnoMage <mla...@technomage.com
<mailto:mla...@technomage.com>> wrote:
I am trying to get a minimal Flink SQL program going to test it
out. I have a StreamExecutionEnvironment and from that created a
StreamTableEnvironment. The docs indicate there should be a
fromDataStream method to create a Table, but none appears to
exist according to Eclipse. The method registerDataStream is
also missing, just registerDataSteramInternal. The Internal
suggests private API to me, so I am asking if the docs are out of
date, or I am missing some library or such. I am using Java 8.0
not Scala.
Michael Latta
