关于Flink:Flink学习笔记

1 概述

Flink是什么?
    Stateful Computations over Data Streams 即 有状态的计算流框架(大数据计算框架)
    
    什么叫做状态?
    对源源不断过去的数据,晓得数据的状态。
    
flink的特点:基于事件处理的框架,即来一条数据就解决一条数据
sparkstreaming: 基于工夫来解决数据,即一个很小的时间段内的数据作为一个批次进行解决。

目前离线批处理spark强,实时处理flink强。

无界数据流:
无界数据流有一个开始然而没有完结,它们不会在生成时终止并提供数据,必须间断解决无界流,也就是说必须在获取后立刻解决event。对于无界数据流咱们无奈期待所有数据都达到,因为输出是无界的,并且在任何工夫点都不会实现。解决无界数据通常要求以特定程序(例如事件产生的程序)获取event,以便可能推断后果完整性。

有界数据流:
有界数据流有明确定义的开始和完结,能够在执行任何计算之前通过获取所有数据来解决有界流,解决有界流不须要有序获取,因为能够始终对有界数据集进行排序,有界流的解决也称为批处理。

评论

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

这个站点使用 Akismet 来减少垃圾评论。了解你的评论数据如何被处理