Watermark是流式处理中的一个基础概念,关于Watermark的概念有很多,在这里不做阐述。
Aerospike(3) - Evict机制
发表于
|
分类于
Aerospike
在实时的场景中,我们往往会对Aerospike/Redis等设置evict机制,来防止流量暴增带来的存储系统崩溃。
Spark - 利用WeakReference来清理对象
发表于
|
分类于
Apache Spark
本文描述了在Spark ContextCleaner中利用WeakReference和referenceQueue来清理无效对象的机制和原理
如何在无Checkpoint时初始化Flink程序的状态?
发表于
|
分类于
Apache Flink
本文针对Apache Flink中Checkpoint/Savepoint无法从0恢复的缺点,给出了三种解决方案。
Oracle SQL - CEP语法梳理
发表于
|
分类于
Apache Flink CEP
实时处理中自然少不了CEP这个重量级功能。其实已经有不少成熟的框架实现了CEP,如Github siddhi和EsperTech,但他们使用了特有的语法来做到开发者的友好交互。那么,把CEP的功能加入到万能的SQL中,是不是很有意思呢?