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> 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 > >
