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

(五)Flink Sink 数据输出

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

目录

(一)基本数据输出

(二)第三方数据输出

(三)自定义输出


(一)基本数据输出

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

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

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

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

http://www.lryc.cn/news/428540.html

相关文章:

  • Spring 注入、注解及相关概念补充
  • 【Linux多线程】线程安全的单例模式
  • 基于jqury和canvas画板技术五子棋游戏设计与实现(论文+源码)_kaic
  • 指针 (四)
  • 便利店(超市)管理系统设计与实现(源码+lw+部署文档+讲解等)
  • Excel中的“块”操作
  • yolo V8训练 长条状目标
  • 数据结构与算法 - 设计
  • 62 网络设备的暗藏的操控者SNMP
  • 华硕飞行堡垒键盘全部失灵【除电源键】
  • 前端字符串将其分割成长度为 32 的子字符串数组
  • 小学二年级数学精选试题
  • 练习题 - 探索正则表达式re功能
  • 【Oracle 11G 配置使用教程1】
  • 【ubuntu24.04】docker pull 配置
  • 《机器学习》—— 通过下采样方法实现银行贷款分类问题
  • Synchronized重量级锁原理和实战(五)
  • linux常用网络工具汇总三
  • Linux中nano编辑器详解
  • 26-vector arraylist和linkedlist的区别
  • 20-redis穿透击穿雪崩
  • Docker使用教程
  • poi-tl循环放图片+文字说明
  • 数据结构之树的存储结构
  • Zotero 常用插件介绍
  • WebSocket协议解析
  • ES6 (一)——ES6 简介及环境搭建
  • HarmonyOS开发案例:列表场景实例-TaskPool
  • 谷歌浏览器如何隐藏书签
  • SQL - 视图