Avatar notebook default
Flink
5篇文章 · 6301字 · 1人关注
  • Join优化

    概述 跟传统的关系型数据库类似，分布式环境中的join在提供优化器“hint”（提示）以告诉优化器选择一些执行策略。目前一些优化提示主要针对批处...

    959 0 2
  • Resize,w 360,h 240
    Flink异步I/O

    1 概述 流计算系统中经常需要与外部系统进行交互，我们通常的做法如向数据库发送用户a的查询请求，然后等待结果返回，在这之前，我们的程序无法发送用...

    0.1 4705 0 5
  • Resize,w 360,h 240
    端到端exactly-once（翻译官方）

    1 概述 在Flink1.4.0中，发布了一个叫做TwoPhaseCommitSinkFunction的特性，该逻辑抽取两阶段提交协议常规逻辑，...

    0.1 2068 0 2
  • Resize,w 360,h 240
    Flink增量快照

    1 概述 Apache Flink是可以进行有状态的流处理，然而，在流处理中什么是状态呢？状态是有过去事件的在内存中的一些操作需要存储，这些存储...

    0.1 3194 0 1
  • Resize,w 360,h 240
    Flink序列化框架分析

    1.Flink的TypeInformation类 TypeInformation是flink中所有类型的基类，其作为生产序列化器和比较的一个工具...

    1.7 1739 0 4

文集作者