知识源于积累,登峰造极源于自律
Flink流式读取文本数据计算过程演示. 文本数据总有一刻能读的完,所以他是有界的. 无界流读的是kafka的数据.
Flink是懒加载的,第一遍会检测整体代码.
并行度设置为1,就是单线程执行,所以Flink是一行一行读取文本数据的, 读一行计算一行.
sum算子是有状态的. 所以他的历史数据是保存在sum算子里面.sum算子做聚合计算的,他是一个有状态的算子.
批处理最终是输出一次,而流处理来一条计算一条.所以他保留了状态.方便后面来一条和前面对比进行计算.
结果演示:
缺失模块。
1、请确保node版本大于6.2
2、在博客根目录（注意不是yilia-plus根目录）执行以下命令：
npm i hexo-generator-json-content --save
3、在根目录_config.yml里添加配置：
jsonContent:
meta: false
pages: false
posts:
title: true
date: true
path: true
text: false
raw: false
content: false
slug: false
updated: false
comments: false
link: false
permalink: false
excerpt: false
categories: false
tags: true
故人的博客
IT周的博客
大胖胖的笔记
常瑞的部落落
Fortune博客
星空下的YZY
pai233的博客
BOBL技术博客
程序员斜阳