flink-user-zh mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "venn" <wxchunj...@163.com>
Subject Scala 异步 io 实现
Date Mon, 08 Jul 2019 10:47:14 GMT
大佬们好:

            在开发Scala 的异步io 的时候遇到点问题,Scala 中没有
RichAsyncFunction(Rich类有open方法,可以做初始化操作 ),Scala 版本的
AsyncFunction 与Java 版本的AsyncFunction不是同一个类,所以不能使用Java 的
RichAsyncFunction,请问各位大佬,怎么实现Scala 的RichAsyncFunction ?

详情如下:

            Scala中 使用 AsyncDataStream.orderedWait[IN, OUT:
TypeInformation](  input: DataStream[IN],  asyncFunction: AsyncFunction[IN,
OUT], timeout: Long,  timeUnit: TimeUnit, capacity: Int) 方法 中的 参数
AsyncFunction 全路径是 :
org.apache.flink.streaming.api.scala.async.AsyncFunction ,但是该类没有对应
的 RichAsyncFunction 的实现。

 

对应的Java 版本  AsyncDataStream.orderedWait[IN, OUT: TypeInformation](
input: DataStream[IN],  asyncFunction: AsyncFunction[IN, OUT], timeout:
Long,  timeUnit: TimeUnit, capacity: Int) 中参数 AsyncFunction 的全路径是 :
org.apache.flink.streaming.api.functions.asyn. AsyncFunction, 有对应的
RichAsyncFunction的实现(见下图)。

 

 

类:org.apache.flink.streaming.api.functions.async. RichAsyncFunction

 



 

 

非常感谢各位大佬回复

Mime
  • Unnamed multipart/related (inline, None, 0 bytes)
View raw message