Repository: bahir-flink Updated Branches: refs/heads/master 9188fd557 -> 3f7223f40
[BAHIR-111] Update imports after FLINK-4707 Since Flink version 1.2.0, the Table API has moved to a new package. See [FLINK-4707]: "Move Table API to org.apache.flink.table" Closes #15 Project: http://git-wip-us.apache.org/repos/asf/bahir-flink/repo Commit: http://git-wip-us.apache.org/repos/asf/bahir-flink/commit/3f7223f4 Tree: http://git-wip-us.apache.org/repos/asf/bahir-flink/tree/3f7223f4 Diff: http://git-wip-us.apache.org/repos/asf/bahir-flink/diff/3f7223f4 Branch: refs/heads/master Commit: 3f7223f40812cacd1c4a43f4d74aad2b76d3822c Parents: 9188fd5 Author: Christian Kadner <[email protected]> Authored: Tue Apr 25 17:47:32 2017 -0700 Committer: Christian Kadner <[email protected]> Committed: Tue Apr 25 17:47:32 2017 -0700 ---------------------------------------------------------------------- .../streaming/connectors/netty/example/StreamSqlExample.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/bahir-flink/blob/3f7223f4/flink-connector-netty/src/test/scala/org/apache/flink/streaming/connectors/netty/example/StreamSqlExample.scala ---------------------------------------------------------------------- diff --git a/flink-connector-netty/src/test/scala/org/apache/flink/streaming/connectors/netty/example/StreamSqlExample.scala b/flink-connector-netty/src/test/scala/org/apache/flink/streaming/connectors/netty/example/StreamSqlExample.scala index da36ff4..e8109cb 100644 --- a/flink-connector-netty/src/test/scala/org/apache/flink/streaming/connectors/netty/example/StreamSqlExample.scala +++ b/flink-connector-netty/src/test/scala/org/apache/flink/streaming/connectors/netty/example/StreamSqlExample.scala @@ -19,8 +19,8 @@ package org.apache.flink.streaming.connectors.netty.example import org.apache.flink.api.java.utils.ParameterTool import org.apache.flink.api.scala._ -import org.apache.flink.api.scala.table._ -import org.apache.flink.api.table.TableEnvironment +import org.apache.flink.table.api.scala._ +import org.apache.flink.table.api.TableEnvironment import org.apache.flink.streaming.api.scala.{DataStream, StreamExecutionEnvironment} /**
