From c59ab5b5f6e7050e128a177384da239aaf7e0e83 Mon Sep 17 00:00:00 2001 From: Alexey Novakov Date: Tue, 17 Dec 2024 10:58:38 +0100 Subject: [PATCH] add implicit converters --- .../src/main/scala/org/apache/flinkx/api/conv.scala | 12 ++++++++++++ 1 file changed, 12 insertions(+) create mode 100644 modules/scala-api/src/main/scala/org/apache/flinkx/api/conv.scala 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 new file mode 100644 index 0000000..0e039ac --- /dev/null +++ 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 +}