简介根据事件时间进行滑动窗口计算。必须要TimeStamp列默认每次输出都包含所有窗口对应的结果值处理迟到的事件watermarking（容忍or丢弃）窗口滑动时间必须小于等于窗口时间。窗口划分规则根据窗口时间和滑动时间来判断输入的事件时间

一、RocketMQ是什么?是一个队列模型的消息中间件，具有高性能、高可靠、高实时、分布式特点；Producer、Consumer、队列都可以分布式；Producer向一些队列轮流发送消息，队列集合称为Topic，Consumer如果做广播

转载自：RDD、DataFrame、DataSet介绍我们每天都在基于框架开发，对于我们来说，一套易于使用的API太重要了。对于Spark来说，有三套API。分别是：RDDDataFrameDataSet三套的API，开发人员就要学三套。不

文章目录Shell标准输入、输出和错误1、标准输入、输出和错误2、重定向符号3、重定向输出4、重定向输入5、重定向标准输出和标准错误6、重定向到空设备7、read命令 Shell标准输入、输出和错误大多数 Unix、Linux 操作系统命