廖嘉逸's Blog

廖嘉逸


  • 首页

  • 归档

  • 关于

  • 分类

  • 搜索

聊聊Apache Flink中的Watermark

发表于 2019-03-23 | 分类于 Apache Flink

Watermark是流式处理中的一个基础概念,关于Watermark的概念有很多,在这里不做阐述。

阅读全文 »

Flink Meetup - 基于Flink的实时用户行为分析

发表于 2019-03-10 | 分类于 Apache Flink
本文阐述了我在2018年Flink Meetup北京站的一次分享。
阅读全文 »

Aerospike(3) - Evict机制

发表于 2019-03-03 | 分类于 Aerospike

在实时的场景中,我们往往会对Aerospike/Redis等设置evict机制,来防止流量暴增带来的存储系统崩溃。

阅读全文 »

CEP In Flink (4) - 使用瓶颈

发表于 2019-02-27 | 分类于 Apache Flink CEP
本文描述了Apache Flink CEP模块中使用的一些瓶颈。
阅读全文 »

CEP In Flink (3) - 匹配事件提取

发表于 2019-02-20 | 分类于 Apache Flink CEP
本文描述了Apache Flink CEP模块中匹配事件的提取过程。
阅读全文 »

CEP In Flink (2) - CEP规则匹配

发表于 2019-02-14 | 分类于 Apache Flink CEP
本文描述了Apache Flink中对CEP规则匹配的原理
阅读全文 »

Spark - 利用WeakReference来清理对象

发表于 2019-02-12 | 分类于 Apache Spark
本文描述了在Spark ContextCleaner中利用WeakReference和referenceQueue来清理无效对象的机制和原理
阅读全文 »

CEP In Flink (1) - CEP规则解析

发表于 2019-01-18 | 分类于 Apache Flink CEP
本文描述了Apache Flink中对CEP规则解析的原理
阅读全文 »

如何在无Checkpoint时初始化Flink程序的状态?

发表于 2018-10-25 | 分类于 Apache Flink
本文针对Apache Flink中Checkpoint/Savepoint无法从0恢复的缺点,给出了三种解决方案。
阅读全文 »

Oracle SQL - CEP语法梳理

发表于 2018-08-25 | 分类于 Apache Flink CEP

实时处理中自然少不了CEP这个重量级功能。其实已经有不少成熟的框架实现了CEP,如Github siddhi和EsperTech,但他们使用了特有的语法来做到开发者的友好交互。那么,把CEP的功能加入到万能的SQL中,是不是很有意思呢?

阅读全文 »
123
Liao Jiayi

Liao Jiayi

Carpe Diem.

25 日志
21 分类
37 标签
GitHub E-Mail StackOverflow
© 2021 Liao Jiayi
由 Hexo 强力驱动
|
主题 — NexT.Mist