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

（五）Flink Sink 数据输出

news 2026/2/9 19:32:10

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

（一）基本数据输出

（二）第三方数据输出

（三）自定义输出

（一）基本数据输出

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

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

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

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

（五）Flink Sink 数据输出

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

编程日记 2024/8/21 1:33:23

Spring 注入、注解及相关概念补充

一、Spring DI 的理解 DI ( Dependency Inject，中文释义：依赖注入)是对 IOC 概念不同角度的描述，是指应用程序在运行时，每一个 bean 对象都依赖 IOC 容器注入到当前 bean 对象所需要的另一个 bean 对象。（例如&#xf…...

编程日记 2024/8/21 1:32:22

【Linux多线程】线程安全的单例模式

文章目录 1. 单例模式与设计模式1.1 单例模式1.2 设计模式1.3 饿汉实现模式与懒汉实现模式1.4 饿汉模式① 饿汉模式的特点② 饿汉式单例模式的实现③ 饿汉式单例模式的优缺点④ 适用场景 1.5 懒汉模式① 懒汉式单例模式的特点② 懒汉式单例模式的实现③ 懒汉式单例模式的优…...

编程日记 2024/8/21 1:23:10

基于jqury和canvas画板技术五子棋游戏设计与实现(论文+源码)_kaic

摘要网络五子棋游戏如今面临着一些新的挑战和机遇。一方面，网络游戏需要考虑到网络延迟和带宽等因素，保证游戏的实时性和稳定性。另一方面，网络游戏需要考虑到游戏的可玩性和趣味性，以吸引更多的玩家参与。本文基于HTML5和Canv…...

编程日记 2024/8/21 1:22:09

指针（四）

一 . 指针的使用和传值调用 （1）strlen 的模拟实现库函数 strlen 的功能是求字符串长度，统计的是字符串中 \0 之前的字符个数，函数原格式如下： 我们的参数 str 接收到一个字符串的起始地址，然后开始统计…...

编程日记 2024/8/21 1:21:07

便利店(超市)管理系统设计与实现(源码+lw+部署文档+讲解等)

文章目录前言具体实现截图详细视频演示技术栈系统测试为什么选择我官方认证玩家，服务很多代码文档，百分百好评，战绩可查！！入职于互联网大厂，可以交流，共同进步。有保障的售后代码参考数据库参…...

编程日记 2024/8/21 1:19:05

Excel中的“块”操作

在Excel中，有offset、index、indirect三个对“区域”操作的函数，是较高版本Excel中“块”操作的利器。 (笔记模板由python脚本于2024年08月20日 19:25:21创建，本篇笔记适合喜欢用Excel处理数据的coder翻阅) 【学习的细节是欢悦的历程】 Pytho…...

编程日记 2024/8/21 1:17:03

yolo V8训练长条状目标

1、说明目标数据集合中有很多长条状图片，如果直接Resize 会严重拉伸，因此采用把长条图像裁剪成2段，然后将裁剪后的2段图片拼接在一起。 2、代码 2.1 C 代码 （部署，模型推理时C ） #include <stdio.h…...

编程日记 2024/8/21 1:14:00

数据结构与算法 - 设计

1. LRU缓存请你设计并实现一个满足 LRU (最近最少使用) 缓存约束的数据结构。实现 LRUCache 类： LRUCache(int capacity) 以正整数作为容量 capacity 初始化 LRU 缓存int get(int key) 如果关键字 key 存在于缓存中，则返回关键字的值&#xff0…...

编程日记 2024/8/21 1:12:59

62 网络设备的暗藏的操控者SNMP

一 SNMP 简介 SNMP（Simple Network Management Protocol，简单网络管理协议）广泛用于网络设备的远程管理和操作。SNMP允许管理员通过NMS对网络上不同厂商、不同物理特性、采用不同互联技术的设备进行管理，包括状态监控、数据采集和故障处理。二 SNMP 网络架构 NMS（Netwo…...

编程日记 2024/8/21 1:10:57

华硕飞行堡垒键盘全部失灵【除电源键】

华硕飞行堡垒FX53VD键盘全部失灵【除电源键】前言一、故障排查二、发现问题三、使用方法总结前言版本型号： 型号 ASUS FX53VD（华硕-飞行堡垒） 板号：GL553VD 故障情况描述： 键盘无法使用，键盘除开机键外…...

编程日记 2024/8/21 1:08:55

前端字符串将其分割成长度为 32 的子字符串数组

技巧分享：将字符串切割后，对list数据进行数据处理要实现这个需求，可以编写一个简单的 JavaScript 函数来处理字符串并将其分割成长度为 32 的子字符串数组。下面是一个具体的实现示例： function splitStringIntoChunks(str) {l…...

编程日记 2024/8/21 1:07:54

小学二年级数学精选试题

小学二年级数学精选试题...

编程日记 2024/8/21 1:05:53

练习题 - 探索正则表达式re功能

在编程的世界里，正则表达式（Regular Expression, 简称re）是一种强大的工具，它能帮助我们有效地处理文本数据。从简单的查找到复杂的字符串操作，正则表达式都能轻松应对。特别是在数据清理、文本分析以及自动化处理等场景中，正则表达式更是不可或缺的利器。本篇文章将深入…...

编程日记 2024/8/21 1:04:52

【Oracle 11G 配置使用教程1】

Oracle11G配置使用教程1 引言图像方式创建数据库一、打开 Database Configuration Assistant二、创建数据库操作三、选择数据库模版四、配置数据库标识五、配置数据库标识六、创建数据库配置监听一、打开创建监听程序二、打开创建监听程序三、重新配置监听程序四、选择监听程序…...

编程日记 2024/8/21 1:03:51

【ubuntu24.04】docker pull 配置

Docker 镜像加速器的方式，看起来不行。阿里云的要先登录。手动拉取tar包的方式，官方dockerhub看起来本身没提供。docker pull 的代理与环境变量的代理不同因此，docker pull gitlab/gitlab-ce:17.3.0-ce.0 使用了全局代理也会失败参考官方文档： Use a proxy server with …...

编程日记 2024/8/21 1:02:49

《机器学习》—— 通过下采样方法实现银行贷款分类问题

文章目录一、什么是下采样方法？二、通过下采样方法实现银行贷款分类问题三、下采样的优缺点一、什么是下采样方法？ 机器学习中的下采样（Undersampling）方法是一种处理不平衡数据集的有效手段，特别是在数据集中某些类…...

编程日记 2024/8/21 1:01:48

Synchronized重量级锁原理和实战(五)

在JVM中,每个对象都关联这一个监视器,这里的对象包含可Object实例和Class实例.监视器是一个同步工具,相当于一个凭证,拿到这个凭证就可以进入临界区执行操作,没有拿到凭证就只能阻塞等待.重量级锁通过监视器的方式保证了任何时间内只允许一个线程通过监视器保护的临界区代码. …...

编程日记 2024/8/21 0:58:45

linux常用网络工具汇总三

linux常用网络工具汇总 6. 抓包工具6.1 wireshark安装界面介绍使用过滤器TCP协议示例关于wireshark的缺点 6.2 tcpdump命令格式关键字使用关于tcpdump的缺点 6.3 fiddler6.4 burpsuite 6. 抓包工具 6.1 wireshark Wireshark（前称Ethereal）是一个网络封…...

编程日记 2024/8/21 0:55:39

Linux中nano编辑器详解

nano 是一个简单的文本编辑器，通常预装在大多数 Linux 发行版中。它非常适合初学者使用，因为它有一个用户友好的界面和易于理解的命令集。下面是对 nano 编辑器的详细说明。启动 nano 要启动 nano 并打开一个文件进行编辑，你可以在终端中输…...

编程日记 2024/8/21 0:54:38

第19节 Node.js Express 框架

Express 是一个为Node.js设计的web开发框架，它基于nodejs平台。 Express 简介 Express是一个简洁而灵活的node.js Web应用框架, 提供了一系列强大特性帮助你创建各种Web应用，和丰富的HTTP工具。使用Express可以快速地搭建一个完整功能的网站。 Expre…...

编程新知 2026/2/8 6:37:43

Vue记事本应用实现教程

文章目录 1. 项目介绍2. 开发环境准备3. 设计应用界面4. 创建Vue实例和数据模型5. 实现记事本功能5.1 添加新记事项5.2 删除记事项5.3 清空所有记事 6. 添加样式7. 功能扩展：显示创建时间8. 功能扩展：记事项搜索9. 完整代码10. Vue知识点解析10.1 数据绑…...

编程新知 2025/9/20 5:20:12

RocketMQ延迟消息机制

两种延迟消息 RocketMQ中提供了两种延迟消息机制指定固定的延迟级别通过在Message中设定一个MessageDelayLevel参数，对应18个预设的延迟级别指定时间点的延迟级别通过在Message中设定一个DeliverTimeMS指定一个Long类型表示的具体时间点。到了时间点后&#xf…...

编程新知 2026/2/8 21:59:25

51c自动驾驶~合集58

我自己的原文哦~ https://blog.51cto.com/whaosoft/13967107 #CCA-Attention 全局池化局部保留，CCA-Attention为LLM长文本建模带来突破性进展琶洲实验室、华南理工大学联合推出关键上下文感知注意力机制（CCA-Attention），…...

编程新知 2026/2/5 4:25:15

《用户共鸣指数（E）驱动品牌大模型种草：如何抢占大模型搜索结果情感高地》

在注意力分散、内容高度同质化的时代，情感连接已成为品牌破圈的关键通道。我们在服务大量品牌客户的过程中发现，消费者对内容的“有感”程度，正日益成为影响品牌传播效率与转化率的核心变量。在生成式AI驱动的内容生成与推荐环境中&#xff0…...

编程新知 2026/2/2 1:48:09

spring：实例工厂方法获取bean

spring处理使用静态工厂方法获取bean实例，也可以通过实例工厂方法获取bean实例。实例工厂方法步骤如下： 定义实例工厂类（Java代码），定义实例工厂（xml），定义调用实例工厂&#xff…...

编程新知 2025/11/25 22:46:30

Spring数据访问模块设计

前面我们已经完成了IoC和web模块的设计，聪明的码友立马就知道了，该到数据访问模块了，要不就这俩玩个6啊，查库势在必行，至此，它来了。一、核心设计理念 1、痛点在哪应用离不开数据（数据库、No…...

编程新知 2026/2/4 16:13:50

3-11单元格区域边界定位(End属性)学习笔记

返回一个Range 对象，只读。该对象代表包含源区域的区域上端下端左端右端的最后一个单元格。等同于按键 End 向上键(End(xlUp))、End向下键(End(xlDown))、End向左键(End(xlToLeft)End向右键(End(xlToRight)) 注意：它移动的位置必须是相连的有内容的单元格…...

编程新知 2026/2/9 15:39:14

GC1808高性能24位立体声音频ADC芯片解析

1. 芯片概述 GC1808是一款24位立体声音频模数转换器（ADC），支持8kHz~96kHz采样率，集成Δ-Σ调制器、数字抗混叠滤波器和高通滤波器，适用于高保真音频采集场景。 2. 核心特性高精度：24位分辨率&#xff0c…...

编程新知 2026/1/27 4:58:14

LLMs 系列实操科普（1）

写在前面： 本期内容我们继续 Andrej Karpathy 的《How I use LLMs》讲座内容，原视频时长 ~130 分钟，以实操演示主流的一些 LLMs 的使用，由于涉及到实操，实际上并不适合以文字整理，但还是决定尽量整理一份笔…...

编程新知 2026/1/31 11:35:24

（一）基本数据输出

相关文章：