Flink SQL questions

[Michael Latta]

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

[Hequn Cheng]

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 <[hidden email]> 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

[Michael Latta]

Thanks, I will check it out. 

Michael

Sent from my iPad

On Nov 1, 2018, at 8:22 PM, Hequn Cheng <[hidden email]> 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 <[hidden email]> 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

[Timo Walther]

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 <[hidden email]> 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 <[hidden email]> 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