本文主要是介绍Flink实例（十八）:Flink 异步IO （三）实例 (一)，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！
生成6条数据，从0开始递增的6个数字。模拟异步查询之后，加上时间戳输出
public class AsyncIODemo {public static void main(String[] args) throws Exception {StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();env.setParallelism(1);final int maxCount = 6;final int taskNum = 1;final long timeout = 40000;DataStream<Integer> inputStream = env.addSource(new SimpleSource(maxCount));AsyncFunction<Integer, String> function = new SampleAsyncFunction();DataStream<String> result = AsyncDataStream.unorderedWait(inputStream,function,timeout,TimeUnit.MILLISECON这篇关于Flink实例（十八）:Flink 异步IO （三）实例 (一)的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！
