Flink实例（十九）:Flink 异步IO （四）实例 (二) MySQL

本文主要是介绍Flink实例（十九）:Flink 异步IO （四）实例 (二) MySQL，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

业务如下：

接收kafka数据，转为user对象，调用async，使用user.id 查询对应的phone，放回user对象，输出

 主类：

import com.alibaba.fastjson.JSON;
import com.venn.common.Common;
import org.apache.flink.formats.json.JsonNodeDeserializationSchema;
import org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.node.ObjectNode;
import org.apache.flink.streaming.api.datastream.AsyncDataStream;
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer;
import java.util.concurrent.TimeUnit;public class AsyncMysqlRequest {public static void main(String[] args) throw

这篇关于Flink实例（十九）:Flink 异步IO （四）实例 (二) MySQL的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！

---