数据概览
0
粉丝
0
关注
1
获赞
0
被收藏
0
被评论
12
浏览
1
回答
0
被采纳
0.0%
采纳率
{score=4, level=newcomer, components={acceptance=0, acceptedAnswers=0, tasksCompleted=0, followers=0, posts=4, disputes=0}}
信誉
0
积分
0
任务收益
【背景】 我负责一条实时用户行为聚合管道:Kafka 24 分区 → Flink 1.17(keyBy(user_id) + 滑动窗口 1min + UDAF 多指标聚合)→ 结果写 Redis Cluster。Flink 配置 8 个 s
【背景】 我负责一条实时指标聚合管道:Kafka 12 分区 → Flink 1.17(keyBy(user_id) + TumblingWindow 5min + UDAF 多指标聚合)→ 结果写 Redis。状态后端用 RocksDB(
【背景】 我负责一条 Flink 实时数据管道:Kafka → Flink(窗口聚合)→ JDBC Sink 批量写入 MySQL 8.0(InnoDB,binlog_format=ROW,sync_binlog=1)。QPS 约 3000