Avatar notebook default
Flink入门
15篇文章 · 10278字 · 1人关注
  • Flink 术语表

    Checkpoint Storagecheckpoint期间State Backend存储snapshot的地方，JobManager的Java...

    0.5 629 0 1
  • Resize,w 360,h 240
    Flink Architecture

    1. Flink 集群组成 Flink 运行时主要由两部分构成（图中橘色部分）： JobManager TaskManager JobManag...

    276 0 0
  • Timely Stream Processing

    Timely Stream Processing只是在Stateful Stream Processing上增加了时间的处理，可用于做特定时间段...

    262 0 0
  • Stateful Streaming Processing

    1. 什么是State 有时候除了一次处理一个event, 我们也想记录处理多个event的信息，这个时候的操作就是stateful有状态的。 ...

    343 0 0
  • Resize,w 360,h 240
    Fault Tolerance

    1. State Backend Flink管理的state存储在state backend里。一种是RocksDB, 一种是JVM heap....

    484 0 0
  • Event-Driven Applications

    1. ProcessFunctions ProcessFunction能够同时处理timers和state，这也是创建event-driven ...

    287 0 0
  • Resize,w 360,h 240
    Streaming Analytics

    1. Event Time and Watermarks Flink 支持三种time模式：event time: 事件发生的时间ingesti...

    587 0 0
  • Data Pipelines & ETL

    Flink一个最常见的use case就是做ETL。 1. Stateless Transformation 无状态的转换最基础的操作就是map...

    2.1 583 0 3
  • Resize,w 360,h 240
    DataStream API介绍

    1. 什么样的数据可以流化 对于Java和Scala来说，凡是可以被序列化的对象都可以流化。Flink自己的序列化器可以用于： 基本数据类型：S...

    432 0 0

文集作者