热门标签
热门文章
- 110 文件
- 2app性能测试点、安全测试点总结
- 3万亿赛道！生成式AI产业落地解决方案深度分析 2024_捕捉生成式ai新机遇
- 4循环生成网络 CycleGan 原理介绍_cyclegan网络
- 5简便高效的Socket通信解决方案：使用C# Winform控件集成服务端和客户端，无需编写冗长代码，C# Winform程序中封装的Socket通信TCP控件，无需编码，直接集成服务端和客户端功能，_winform socket
- 6【视频理解】十一、Non-Local☆_non-local网络
- 7Rust实战：单元测试与集成测试技巧解析_rust 单元测试
- 8Idea集成scala_scala对应jdk版本
- 9在Linux系统上安装和配置Redis数据库，无需公网IP即可实现远程连接的详细解析_非root用户在linux安装redis,并允许远程连接此数据库
- 10【yolov8 项目打包】pyinstaller 打包pyQt5 界面为exe_yolov8和pyside6转exe
当前位置: article > 正文
数据湖（十六）：Structured Streaming实时写入Iceberg_structstreaming后如何实时可视化
作者：在线问答5 | 2024-07-23 12:17:12
赞
踩
structstreaming后如何实时可视化
文章目录
Structured Streaming实时写入Iceberg
三、编写Structured Streaming读取Kafka数据实时写入Iceberg
Structured Streaming实时写入Iceberg
目前Spark中Structured Streaming只支持实时向Iceberg中写入数据，不支持实时从Iceberg中读取数据，下面案例我们将使用Structured Streaming从Kafka中实时读取数据，然后将结果实时写入到Iceberg中。
一、创建Kafka topic
启动Kafka集群，创建“kafka-iceberg-topic”
[root@node1 bin]# ./kafka-topics.sh --zookeeper node3:2181,node4:2181,node5:2181 --create --topic kafka-iceberg-topic --partitions 3 --replication-factor 3推荐阅读
相关标签
