flink日记

直接下载 解压,

运行 ./bin/start-cluster.sh     

几个概念:

         批处理: 大数据量,不要求实时。 输入源是有界的

         流处理:实时要求高,通常在毫秒级, 数据量比较小,但是输入源是无界的

采集 (来源MQ, stream...)--> translate(实时计算,批计算) --> sink (保存到数据库或者mq)

idea中调试flink程序

StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
可以自动查找到当前flink环境


原文地址:https://www.cnblogs.com/yszzu/p/10089958.html