240 发简信
IP属地:上海
  • 120
    浅谈Java SPI原理与其在JDBC、Flink中的应用

    API vs SPI API(Application Programming Interface)的概念对我们来说已经是见怪不怪了。在日常开发过程中,我们需要调用平台/框架提...

  • 120
    Flink 源码分析系列文档目录

    Flink系列文档脑图 由于源码分析系列文档较多,本人绘制了Flink文档脑图。和下面的文档目录对应。各位读者可以选择自己感兴趣的模块阅读并参与讨论。 此脑图不定期更新中……...

  • 120
    Flink Join实现

    Window Join 基于窗口的Join是将具有相同key并位于同一个窗口中的事件进行联结。 用法: 官方案例: Tumbling Window Join的实现,关于其他的...

  • Flink源码之Trigger

    什么是Trigger Flink中Trigger用于定义何时对窗口进行计算并发出结果,它的触发条件可以是时间也可以是某些特定条件。对于时间窗口而言,默认Trigger是处理时...

  • 120
    实时数仓-Flink窗口的实现与应用

    本文档整理于Flink社区直播课Flink窗口是实时处理非常重要的技术,广泛用于实时ETL、实时报表以及一些实时的监控。 学习路线 为什么要关心实现 ReduceFuncti...

  • Flink状态与容错

    一致性检查点 1.什么是一致性检查点 Flink故障恢复机制的核心,就是应用的一致性检查点。有状态应用的一致性检查点,就是所有任务的状态,在某个时间点的一份快照。这个时间点,...

  • 新生代的

    GC回收过程

    1)新生代老生代 Java堆中的内存分两块: 新生代:新创建的对象 老生代:创建时间比较长的对象 两代主要用于JVM的GC操作, 新生代经常的被GC 老生代不经常被GC 永久...