这里写自定义目录标题# 系列文章目录监控系统--flink+kafka实现Exactly Once前言一、pandas是什么?二、使用步骤1.引入库2.读入数据总结前言一、pandas是什么?二、使用步骤1.引入库2.读入数据总结欢迎使用Markdown编辑器新的改变功能......
2023-10-11 21:17 阅读 阅读全文文章浏览阅读3.1k次。TS流的结构TS流由很多个TS包组成,而每个TS包的结构包括:4B的包头,可变长的调整字段,有效净荷(payload)。现在分别说一下这三部分的结构和作用。包头包头最小为4字节,这四字节分为8个部分分别......
2023-11-13 21:19 阅读 阅读全文文章浏览阅读404次。react grpc 大家好! 在本文中,我将解释如何在Appwish项目中使用Vert.x,gRPC和GraphQL为UI应用程序提供API。 我们将使用两个后端微服务作为示例-graphqlapi和wishservice 。 如果您不熟悉Appwish,那么这是我两个星期前......
2024-01-22 22:16 阅读 阅读全文文章浏览阅读3.7k次,点赞4次,收藏10次。解决flink问题小技巧: 一般使用flink中出现了问题, 可以在Apache Flink 中文用户邮件列表:http://apache-flink.147419.n8.nabble.com/找一下, 是不是有人也遇到过这样的问题两种方案:1: 通过state......
2024-01-23 07:35 阅读 阅读全文文章浏览阅读744次。正如刚才所说,TensorFlow 是一个开源的机器学习框架,由谷歌开发与维护,并被用在谷歌的很多产品中,例如 Gmail、Google Photos、语音识别。但其实,无论是整个行业的研究领域还是实际工业中,TensorFlow 使用......
2024-01-25 04:57 阅读 阅读全文文章浏览阅读1.6k次。1、Spark Streaming简介1.1 概述Spark Streaming 是Spark核心API的一个扩展,可以实现高吞吐量的、具备容错机制的实时流数据的处理。支持从多种数据源获取数据,包括Kafk、Flume、Twitter、ZeroMQ、Kinesis 以及TCP sockets,......
2024-01-24 06:48 阅读 阅读全文文章浏览阅读170次。 Spark Streaming 是 Spark Core API 的扩展,它支持弹性的,高吞吐的,容错的实时数据流的处理。数据可以通过多种数据源获取,例如 Kafka,Flume,Kinesis 以及 TCP sockets,也可以通过例如 map,reduce,join,window 等......
2024-01-24 07:04 阅读 阅读全文文章浏览阅读1.1k次。需求:表格上方有一个导出按钮,点击后,调用后台接口,后台返回数据流,下载成功后并在本地可以打开excel。代码实现:<el-button type="primary" size="mini" icon="el-icon-download" @click="......
2024-01-21 11:05 阅读 阅读全文文章浏览阅读490次,点赞2次,收藏2次。文章目录IO流概述IO流概述什么是IO流I:inputO:output通过IO就可以完成硬盘文件的读和写硬盘中的文件加载到内存就是输入(Input)、内存将使用或者修改过的文件再返回给硬盘就是输出(Output......
2023-11-11 13:58 阅读 阅读全文文章浏览阅读211次。1. Flink中窗口的API分类在Flink流计算中,提供Window窗口API分为两种1)、针对KeyedStream窗口API:window第一步、数据流DataStream调用keyBy函数分组,获取KeyedStream第二步、KeyedStream.window设置窗口第三步、聚合操作,对......
2024-01-23 11:29 阅读 阅读全文