Skip to content

Commit 84e33e0

Browse files
add implicit converters (#194)
1 parent d9588d0 commit 84e33e0

File tree

1 file changed

+12
-0
lines changed
  • modules/scala-api/src/main/scala/org/apache/flinkx/api

1 file changed

+12
-0
lines changed
Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,12 @@
1+
package org.apache.flinkx.api
2+
3+
import org.apache.flink.streaming.api.environment.{StreamExecutionEnvironment => JavaEnv}
4+
import org.apache.flink.streaming.api.datastream.{DataStream => JavaStream}
5+
6+
import scala.language.implicitConversions
7+
8+
object conv {
9+
implicit def toJavaEnv(e: StreamExecutionEnvironment): JavaEnv = e.getJavaEnv
10+
11+
implicit def toJavaDataStream[T](d: DataStream[T]): JavaStream[T] = d.javaStream
12+
}

0 commit comments

Comments
 (0)