Flink Timer(定时器)机制及实现详解

Timer是Flink Streaming API提供的用于感知并利用处理时间/事件时间变化的机制。官网上给出的描述如下:Timers are what make Flink streaming applications reactive and adaptable to processing and event time changes.

Spark Streaming+Kafka的嵌入方式及应用

之后简单阐述Sparkstreaming+kafka在舆情项目中的应用,最后将自己在SparkStreaming+kafka的实际优化中的一些经验进行归纳总结。

网站地图