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.
Am 02.11.18 um 04:32 schrieb Michael Latta:
Thanks, I will check it out.
Sent from my iPad
There are some test cases in Flink git, such as
which I think may help you.
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