240 投稿
Flink专题
收录了17篇文章 · 30人关注
  • Resize,w 360,h 240
    分布式一致性算法：Raft 算法（Raft 论文翻译）

    可进入我的博客查看原文。 Raft 算法是可以用来替代 Paxos 算法的分布式一致性算法，而且 raft 算法比 Paxos 算法更易懂且更容...

    2.7 Jeffbond 4 91 1
  • Resize,w 360,h 240
    在Apache Flink中Savepoints和CheckPoints的三点不同(译文)

    翻译自：3 differences between Savepoints and Checkpoints in Apache Flink本文发布...

    第十人_孔 0 0
  • Resize,w 360,h 240
    Kafka史上最详细原理总结上

    Kafka史上最详细原理总结分为上下两部分，承上启下 Kafka史上最详细原理总结上 Kafka史上最详细原理总结下 Kafka Kafka是最...

    13.3 小波同学 6 219
  • Resize,w 360,h 240
    Flink Table API 和SQL的流处理

    Flink 的 Table API 和SQL支持是用于批处理和流处理的统一API。这意味着 Table API 和SQL查询具有相同的语义，无论...

    0.9 Alex90 2 4
  • Flink 指标（二）

    报告（Reporter） 通过 conf/flink-conf.yaml 文件配置一个或多个 Reporters 来暴露度量值给外部系统，这些 ...

    0.5 Alex90 0 2
  • Flink 指标（一）

    Flink 自带一个度量系统，允许收集和公开指标到外部系统。 注册指标 可以通过继承 RichFunction，在继承类里面调用 getRunt...

    0.4 Alex90 0 1
  • Flink Table API 和 SQL

    Apache Flink 具有两个关系型API：Table API 和SQL，用于统一流和批处理。Table API 是用于 Scala 和 J...

    1.6 Alex90 0 10
  • Flink DataSet API

    Data Source Data Source 创建初始数据集。Flink 附带了几种内置输入格式，可以从通用文件格式创建数据集。Executi...

    0.2 Alex90 0 2
  • Flink DataStream API

    Data Sources 源是程序读取输入数据的位置。可以使用 StreamExecutionEnvironment.addSource(sou...

    0.1 Alex90 0 1
  • Flink DataStream Side Output

    Side Output 功能从 Flink 1.3.0 版本开始提供，FLINK-4460 除了从 DataStream 操作的结果中获取主数据...

    Alex90 0 0