240 投稿
flink
收录了19篇文章 · 7人关注
  • Resize,w 360,h 240
    Flink RichFunction&state

    本文大纲1 RichFunction2 RichMapFunction3 state4 keyed state4.1 keyedState简单示...

    知识海洋中的淡水鱼 3 3
  • Resize,w 360,h 240
    Flink DataStream API详解

    Flink API介绍 Flink提供了三层API，每层在简洁性和表达性之间进行了不同的权衡。 ProcessFunction是Flink提供的...

    1.6 零度沸腾_yjz 0 19
  • Resize,w 360,h 240
    Flink 原理与实现：内存管理

    如今，大数据领域的开源框架（Hadoop，Spark，Storm）都使用的 JVM，当然也包括 Flink。基于 JVM 的数据分析引擎都需要面...

    12.8 尼小摩 0 17
  • Resize,w 360,h 240
    【Flink】Flink集群部署与YARN集成

    1、Standalone 软件要求： Java 1.8.x or higher ssh JAVA_HOME配置 You can set this...

    0.4 JACKbayue 0 6
  • Resize,w 360,h 240
    玩转KafkaIO与Flink

    随着大数据 2.0 时代悄然到来，大数据从简单的批处理扩展到了实时处理、流处理、交互式查询和机器学习应用。近年来涌现出诸多大数据应用组件，如 H...

    0.3 Java大生 0 6
  • Flink：特性、概念、组件栈、架构及原理分析

    简单之美 | Apache Flink：特性、概念、组件栈、架构及原理分析http://shiyanjun.cn/archives/1508.h...

    0.2 葡萄喃喃呓语 0 27
  • Resize,w 360,h 240
    Operators

    原文链接 操作符将一个或多个DataStream转换成为新的DataStream。程序可以将多个转换组合成复杂的数据流拓步。 本节给出了基本转换...

    小C菜鸟 0 0
  • Resize,w 360,h 240
    Event Time

    原文链接 事件时间 /处理时间/摄入时间 Flink支持流操作中不同的时间概念。 处理时间: 处理时间是指执行相应操作的机器的系统时间。当流程序...

    小C菜鸟 0 0
  • Checkpoints

    原文链接 概述 Checkpoint通过允许从状态和相应流的位置进行恢复，从而使Flink中的状态具备容错能力，从而使应用程序具有与无故障执行相...

    小C菜鸟 0 0
  • Checkpointing

    原文链接 Flink中的每个函数和操作符都可以是有状态的(详细信息请参阅使用状态)。有状态的函数在单个元素/事件的处理过程中存储数据，使状态成为...

    小C菜鸟 0 0

专题公告

flink