1.安装java1.8版本steven@wangyuxiangdeMacBook-Pro~java-versionjavaversion"1.8.0_211"Java(TM)SERuntimeEnvironment(build1.8.0_211-b12)JavaHotSpot(TM)64-BitServerVM(build25.211-b12,mixedmode)2.安装flink使用brew安装flink，命令如下：brewinstallapache-flink3.查看是否安装成功steven@wangyuxiangdeMacBook-Pro~flink-vVersion:1.13.2,
目录状态概述算子状态键控状态状态后端状态概述在目前所有流式计算的场景中，将数据流的状态分为有状态和无状态两种类型。无状态指的就是无状态的计算观察每个独立的事件，并且只根据最后一个事件输出结果。举个栗子：一个流处理程序，从传感器接收温度数据然后在温度为90摄氏度发出报警信息。有状态的计算则会根据多个事件输出结果。举个栗子：计算过去一小时的平均温度，就是有状态的计算、若在一分钟内收到两个相差20度以上的温度读数，则发出警告等等。对照上图可以看出：无状态流处理分别接收每条数据记录，然后根据最新输入的数据生成输出数据。（每次只转换一条输入记录，并且仅根
目录状态概述算子状态键控状态状态后端状态概述在目前所有流式计算的场景中，将数据流的状态分为有状态和无状态两种类型。无状态指的就是无状态的计算观察每个独立的事件，并且只根据最后一个事件输出结果。举个栗子：一个流处理程序，从传感器接收温度数据然后在温度为90摄氏度发出报警信息。有状态的计算则会根据多个事件输出结果。举个栗子：计算过去一小时的平均温度，就是有状态的计算、若在一分钟内收到两个相差20度以上的温度读数，则发出警告等等。对照上图可以看出：无状态流处理分别接收每条数据记录，然后根据最新输入的数据生成输出数据。（每次只转换一条输入记录，并且仅根
概述在之前总结的文章中有提到过，Flink框架提供了三层API完成流处理任务。至此已经学习了DataStreamAPI，ProcessFunctionAPI是Flink中最底层的API，可以访问时间戳、watermark以及注册定时事件。还可以输出特定的一些事件。、ProcessFunction用来构建事件驱动的应用以及实现自定义的业务逻辑，若窗口函数以及转换算子都无法满足业务的要求时，需要请出ProcessFunction去完成开发任务。FlinkSQL就是使用ProcessFunction实现的。Flink提供了8个ProcessFunction如下：ProcessFunction
概述在之前总结的文章中有提到过，Flink框架提供了三层API完成流处理任务。至此已经学习了DataStreamAPI，ProcessFunctionAPI是Flink中最底层的API，可以访问时间戳、watermark以及注册定时事件。还可以输出特定的一些事件。、ProcessFunction用来构建事件驱动的应用以及实现自定义的业务逻辑，若窗口函数以及转换算子都无法满足业务的要求时，需要请出ProcessFunction去完成开发任务。FlinkSQL就是使用ProcessFunction实现的。Flink提供了8个ProcessFunction如下：ProcessFunction
我的gitee地址：https://gitee.com/ddxygq/bigdata-technical-pai最近看到有人在用flinksql的页面管理平台，大致看了下，尝试安装使用，比原生的flinksql界面确实好用多了，我们看下原生的，通过bin/sql-client.sh命令进入那个黑框，一只松鼠，对，就是那个界面。。。。这个工具不是Flink官方出的，是一个国内的小伙伴写的，Github地址：https://github.com/zhp8341/flink-streaming-platform-web根据github上，作者的描述，flink-streaming-patform-w
我的gitee地址：https://gitee.com/ddxygq/bigdata-technical-pai最近看到有人在用flinksql的页面管理平台，大致看了下，尝试安装使用，比原生的flinksql界面确实好用多了，我们看下原生的，通过bin/sql-client.sh命令进入那个黑框，一只松鼠，对，就是那个界面。。。。这个工具不是Flink官方出的，是一个国内的小伙伴写的，Github地址：https://github.com/zhp8341/flink-streaming-platform-web根据github上，作者的描述，flink-streaming-patform-w
