当前位置: 首页 > news >正文

(五)Flink Sink 数据输出

经过上面的 Transformation 操作之后,最终形成用户所需要的结果数据集。通常情况下,用户希望将结果数据输出到外部存储介质或者传输到下游的消息中间件中,在 Flink 中,将 DataStream 数据输出到外部系统的过程被定义为 Sink 操作。

目录

(一)基本数据输出

(二)第三方数据输出

(三)自定义输出


(一)基本数据输出

  • writeAsText( ) :将元素转为 String 类型按行写入外部输出。
  • writeAsSocket( ) :将元素写入 Socket
  • writeAsCsv( ) :将元素写入文本

下面我们将通过使用 writeAsSocket() 的方式实验,完成 Sink 数据输出。

重写第二章《程序运行结构》中的案例,使用 writeAsSocket() 方式,通过统计 9999 端口输入的文本数量,将结果写入到 9998 端口的控制端。

1.修改第二章案例代码,具体


http://www.mrgr.cn/news/4291.html

相关文章:

  • 深入探索CSS的:local-link伪类:选择指向同一文档的链接
  • 一款功能强大的本地数据全文搜索引擎Anytxt Searcher
  • 中控室控制台怎样选择合适的款式?
  • [鹏城杯 2022]简单的php
  • [C++] C++11详解 (一)
  • Python知识点:如何使用Terraform与Python进行基础设施即代码管理
  • 的卢易表:批量处理Excel数据的自动化工具
  • [000-01-022].第06节:RabbitMQ中的交换机介绍
  • 力扣221题详解:最大正方形的多种解法与模拟面试问答
  • DrissionPage自动化获取城市数据内容
  • C++ //练习 19.5 在什么情况下你应该使用dynamic_cast替代虚函数?
  • 【通用】C++ union(联合体)
  • 嵌入式堆栈、ARM寄存器
  • React+TS+useReducer手撕一个todoList
  • MySQL中的EXPLAIN的详解
  • CentOS 上安装 Java 17
  • F. Valuable Cards D. Smithing Skill
  • 安装CUDA、CUDNN、pytorch
  • 【YOLO家族】Scaled-YOLOv4, Optimal Speed and Accuracy of Object Detection,CVPR 2021
  • 一起学习LeetCode热题100道(52/100)