[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

Re: Flink SQL questions

Hi Michael,

There are some test cases in Flink git, such as[1] which I think may help you.

Best, Hequn

On Fri, Nov 2, 2018 at 7:46 AM TechnoMage <mlatta@xxxxxxxxxxxxxx> 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