算子reduceBykeyval dataRDD1 = sparkContext.makeRDD(List(("a",1),("b",2),("c",3))) val dataRDD2 = dataRDD1.reduceByKey(_+_)

0x0.Standalone模式快速上手 #解压缩 tar -zxvf flink-1.10.1-bin-scala_2.12.tgz -C /opt/module #修改flink/conf/flink-conf.yaml配置文件 job

本文主要介绍了processAPI的使用与实战,状态的后端的内存管理,RockSDB的进阶