大佬们好: 在开发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 非常感谢各位大佬回复 |
Your scala asyncFunction can extends
org.apache.flink.streaming.api.functions.async.RichAsyncFunction directly. venn <[hidden email]> 于2019年7月8日周一 下午6:47写道: > 大佬们好: > > 在开发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 > > > > > > > > 非常感谢各位大佬回复 > |
Thanks for your attention, as your words the " org.apache.flink.streaming.api.functions.async.RichAsyncFunction " extend " org.apache.flink.streaming.api.functions.asyn.AsyncFunction", but Scala AsyncDataStream.orderedWait parameter AsyncFunction full path is " org.apache.flink.streaming.api.scala.async.AsyncFunction", there are different
-----邮件原件----- 发件人: user-zh-return-554-wxchunjhyy=[hidden email] <user-zh-return-554-wxchunjhyy=[hidden email]> 代表 Lin Li 发送时间: Monday, July 8, 2019 6:51 PM 收件人: [hidden email] 主题: Re: Scala 异步 io 实现 Your scala asyncFunction can extends org.apache.flink.streaming.api.functions.async.RichAsyncFunction directly. venn <[hidden email]> 于2019年7月8日周一 下午6:47写道: > 大佬们好: > > 在开发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 > > > > > > > > 非常感谢各位大佬回复 > |
If you can not switch to java AsyncDataStream API, then you can consider
upgrading to flink-1.8.0+, FLINK-6756 has provided RichAsyncFunction to Scala API. venn <[hidden email]> 于2019年7月9日周二 上午9:37写道: > Thanks for your attention, as your words the " > org.apache.flink.streaming.api.functions.async.RichAsyncFunction " extend " > org.apache.flink.streaming.api.functions.asyn.AsyncFunction", but Scala > AsyncDataStream.orderedWait parameter AsyncFunction full path is " > org.apache.flink.streaming.api.scala.async.AsyncFunction", there are > different > > -----邮件原件----- > 发件人: user-zh-return-554-wxchunjhyy=[hidden email] > <user-zh-return-554-wxchunjhyy=[hidden email]> 代表 Lin Li > 发送时间: Monday, July 8, 2019 6:51 PM > 收件人: [hidden email] > 主题: Re: Scala 异步 io 实现 > > Your scala asyncFunction can extends > org.apache.flink.streaming.api.functions.async.RichAsyncFunction directly. > > venn <[hidden email]> 于2019年7月8日周一 下午6:47写道: > > > 大佬们好: > > > > 在开发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 > > > > > > > > > > > > > > > > 非常感谢各位大佬回复 > > > |
Free forum by Nabble | Edit this page |