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

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

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

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

Hdfs Sink
Starrock Sink
MysqlSink
Kafka Sink
SinkBuilder

目前支持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

边栏推荐

day7-列表作业(1)
【过一下4】09-10_经典网络解析
HQL statement execution process
Wise Force Deleter强制删除工具
Using pip to install third-party libraries in Pycharm fails to install: "Non-zero exit code (2)" solution
CAP+BASE
机器学习(一) —— 机器学习基础
SQL(一) —— 增删改查
怎么更改el-table-column的边框线
The difference between the operators and logical operators

随机推荐

物理层的接口有哪几个方面的特性？各包含些什么内容？
周末作业-循环练习题(2)
小白一枚各位大牛轻虐虐
2022牛客多校第四场C.Easy Counting Problem（EGF+NTT）
机器学习(二) —— 机器学习基础
Detailed Explanation of Redis Sentinel Mode Configuration File
数据库单表查询
【解码工具】Bitcoin的一些在线工具
OFDM 十六讲 5 -Discrete Convolution, ISI and ICI on DMT/OFDM Systems
OFDM Lecture 16 5 -Discrete Convolution, ISI and ICI on DMT/OFDM Systems
Mysql5.7 二进制部署
SQL(一) —— 增删改查
LeetCode: 1403. Minimum subsequence in non-increasing order [greedy]
range函数作用
In Opencv, imag=cv2.cvtColor(imag,cv2.COLOR_BGR2GRAY) error: error:!_src.empty() in function 'cv::cvtColor'
server disk array
el-pagination左右箭头替换成文字上一页和下一页
实现跨域的几种方式
学习总结week2_5
【过一下14】自习室的一天

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

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

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

Hdfs Sink

边栏推荐

猜你喜欢

随机推荐