发布网友 发布时间:2022-04-23 20:16
共1个回答
热心网友 时间:2023-10-08 21:41
摘要您好,flink项目总计算的需求如下:每分钟统计一次当前分钟内的wordcount,并输出每10s统计一次最近一分钟内的wordcount,并输出从每天0时刻起,每分钟输出一次从0时刻截至到当前时刻的wordcount,并每分钟输出一次,24时重新计算从mysql等系统获取维表,按照不同的业务组做wordcount咨询记录 · 回答于2021-10-23flink项目总计算的有那些需求您好,flink项目总计算的需求:管理抽象:JobManager (Master) :负责调度任务执行、负责指挥进行检查点、负责任务失败容错恢复等。TaskManager (Worker) :负责具体任务的执行、缓存和交换数据流等。每个管理者都对应着独立的JVM进程。flink项目总计算的有哪些需求每分钟统计一次当前分钟内的wordcount,并输出每10s统计一次最近一分钟内的wordcount,并输出从每天0时刻起,每分钟输出一次从0时刻截至到当前时刻的wordcount,并每分钟输出一次,24时重新计算从mysql等系统获取维表,按照不同的业务组做wordcount???。您好,flink项目总计算的需求如下:每分钟统计一次当前分钟内的wordcount,并输出每10s统计一次最近一分钟内的wordcount,并输出从每天0时刻起,每分钟输出一次从0时刻截至到当前时刻的wordcount,并每分钟输出一次,24时重新计算从mysql等系统获取维表,按照不同的业务组做wordcount项目中有哪些维度表?事实表和维度表关键的方案,两种???您好,您提出的问题是“flink项目总计算的有那些需求”哦~我们当前只针对您首次提出的问题进行解答,若有其它问题可重新提问哦~