当前位置：网站首页>基于Flink CDC实现实时数据采集(四）-Sink接口实现

基于Flink CDC实现实时数据采集(四）-Sink接口实现

2022-08-05 05:14:00 【IT_xhf】

基于Flink CDC实现实时数据采集(四）-Sink接口实现


目前支持Hdfs、StarRocks、Mysql、Kafka端写入，每个写入分别都实现AbstractSink接口

Hdfs Sink

/** * { * "targetType":"hdfs", * "targetConfig":{ * "targetPath":"xxxxxxxxxx", * "partition":true * } * } * @author xiaohf7 * @date 2022/4/12 9:37 * @Description */
public class HdfsSink extends
原网站

版权声明
本文为[IT_xhf]所创，转载请带上原文链接，感谢
https://blog.csdn.net/IT_xhf/article/details/126129352

边栏推荐

猜你喜欢

随机推荐