add table api conversion method

Author: novakov-alexey

build.sbt

@@ -21,13 +21,14 @@ lazy val `scala-api` = (project in file("modules/scala-api"))
     scalaVersion       := rootScalaVersion,
     crossScalaVersions := crossVersions,
     libraryDependencies ++= Seq(
-      "org.apache.flink"  % "flink-streaming-java" % flinkVersion % Provided,
-      "org.apache.flink"  % "flink-java"           % flinkVersion % Provided,
-      "org.apache.flink"  % "flink-test-utils"     % flinkVersion % Test,
-      ("org.apache.flink" % "flink-streaming-java" % flinkVersion % Test).classifier("tests"),
-      "org.typelevel"    %% "cats-core"            % "2.12.0"     % Test,
-      "org.scalatest"    %% "scalatest"            % "3.2.19"     % Test,
-      "ch.qos.logback"    % "logback-classic"      % "1.5.16"     % Test
+      "org.apache.flink"  % "flink-streaming-java"        % flinkVersion % Provided,
+      "org.apache.flink"  % "flink-java"                  % flinkVersion % Provided,
+      "org.apache.flink"  % "flink-table-api-java-bridge" % flinkVersion % Provided,
+      "org.apache.flink"  % "flink-test-utils"            % flinkVersion % Test,
+      ("org.apache.flink" % "flink-streaming-java"        % flinkVersion % Test).classifier("tests"),
+      "org.typelevel"    %% "cats-core"                   % "2.12.0"     % Test,
+      "org.scalatest"    %% "scalatest"                   % "3.2.19"     % Test,
+      "ch.qos.logback"    % "logback-classic"             % "1.5.16"     % Test
     ),
     libraryDependencies ++= {
       if (scalaBinaryVersion.value.startsWith("2")) {

modules/scala-api/src/main/scala/org/apache/flinkx/table/api/ops.scala

@@ -0,0 +1,12 @@
+package org.apache.flinkx.table.api
+
+import org.apache.flinkx.api.DataStream
+
+import org.apache.flink.table.api.bridge.java.StreamTableEnvironment
+import org.apache.flink.table.api.Table
+import org.apache.flink.types.Row
+
+implicit class ops(tEnv: StreamTableEnvironment) {
+  def toStream(table: Table): DataStream[Row] =
+    DataStream(tEnv.toDataStream(table))
+}