OldCamel
往期整理
历史归档
文章分类
文章标签
OldCamel | 振衣笑赴千尘浪,濯足醉踏万里流
0
7.流处理API(数据源+算子)
字数
2430
阅读时长≈
7
分钟
2024-10-9
你好!我是OldCamel
OldCamel
目录
Environment
1.getExecutionEnvironment
2.createLocalEnvironment
3.createRemoteEnvironment
Source
1.从集合读取数据
输出
从文件读取数据
输出
从Kafka读取数据
安装kafka
添加依赖
启动zookeeper
启动kafka服务
启动kafka生产者
java程序
运行java代码,在Kafka生产者console中输入
控制台输出
自定义数据源
java
结果
Transform(转换算子)
基本转换算子
输出
聚合操作算子
keyBy
Rolling Aggregation
输出
reduce
输出
支持的数据类型
基础数据类型
Java和Scala元组(Tuples)
Scala样例类(case classes)
Java简单对象(POJO)
其他(Arrays, Lists, Maps, Enums,等等)
最新发布
windows docker 启动失败
2025-2-19
C盘清理记录
2025-1-13
flowable获取下一步会创建的用户任务
2024-12-5
Flink Sql 实现CDC数据实时同步特殊处理
2024-12-5
VictoriaMetrics(一)安装VictoriaMetrics
2024-12-5
VictoriaMetrics(二)安装Grafana
2024-12-5
大数据
8
开发
5
K8S
5
kafka
4
VictoriaMetrics
4
推荐
3
工具
3
流程引擎
2
Flink
2
学习
2
思考
1
Prometheus
1
转载
1
Clickhouse
1
文章数:
28
建站天数:
1773 天
访问量:
访客数: