美文网首页flink流计算
专题列表页
flink流计算

spark 是批计算,将 DAG 划分为不同的 stage,一个完成后才可以计算下一个。flink 是标准的流执行模式,一个事件在一个节点处理完后可以直接发往下一个节点进行处理

  • 0
    2021-07-13
  • Flink分布式缓存分布式缓存 Flink提供了一个分布式缓存,类似于hadoop,可以使用户在并行函数中很方便的读取本地文件,并把它...[作者空间]

  • 0
    2021-07-09
  • Flink 广播变量简介 在Flink中,同一个算子可能存在若干个不同的并行实例,计算过程可能不在同一个Slot中进行,不同算子之间更...[作者空间]

  • 0
    2021-07-09
  • Flink重启策略重启机制 Flink支持不同的重启策略,以在故障发生时控制作业如何重启 集群在启动时会伴随一个默认的重启策略,在没...[作者空间]

  • 0
    2021-07-07
  • Flink检查点机制与状态管理1 检查点机制 1.1 CheckPoints 为了使 Flink 的状态具有良好的容错性,Flink 提供了检查...[作者空间]

  • 0
    2021-06-30
  • Flink Window API窗口(window)就是将无限流切割为有限流的一种方式,它会将流数据分发到有限大小的桶(bucket)中进行分析 ...[作者空间]

  • 0
    2021-06-29
  • Flink运行架构运行时组件 作业管理器(JobManager) 控制一个应用程序执行的主进程,也就是说,每个应用程序都会被一个不同...[作者空间]