add implicit converters

flink-extended · Dec 17, 2024 · c59ab5b · c59ab5b
1 parent 63b1934
commit c59ab5b
Showing 1 changed file with 12 additions and 0 deletions.
diff --git a/modules/scala-api/src/main/scala/org/apache/flinkx/api/conv.scala b/modules/scala-api/src/main/scala/org/apache/flinkx/api/conv.scala
@@ -0,0 +1,12 @@
+package org.apache.flinkx.api
+
+import org.apache.flink.streaming.api.environment.{StreamExecutionEnvironment => JavaEnv}
+import org.apache.flink.streaming.api.datastream.{DataStream => JavaStream}
+
+import scala.language.implicitConversions
+
+object conv {
+  implicit def toJavaEnv(e: StreamExecutionEnvironment): JavaEnv = e.getJavaEnv
+
+  implicit def toJavaDataStream[T](d: DataStream[T]): JavaStream[T] = d.javaStream
+}