什么是有界流和无界流？

有界流

有定义流的开始，也有定义流的结束。
有界流可以在摄取所有数据后再进行计算。
有界流所有数据可以被排序，所以并不需要有序摄取。
有界流处理通常被称为批处理。

有界流，Flink则由一些专为固定大小数据集特殊设计的算法和数据结构进行内部处理，产生了出色的性能。

无界流

有定义流的开始，但没有定义流的结束。
它们会无休止地产生数据。
无界流的数据必须持续处理，即数据被摄取后需要立刻处理。我们不能等到所有数据都到达再处理，因为输入是无限的，在任何时候输入都不会完成。
处理无界数据通常要求以特定顺序摄取事件，例如事件发生的顺序，以便能够推断结果的完整性。

Flink 擅长精确的时间控制和状态化，使得 Flink 的运行时(runtime)能够运行任何处理无界流的应用。

Flink-有界流与无界流相关推荐

Flink——有界流VS无界流
什么是有界流和无界流? 有界流有定义流的开始,也有定义流的结束. 有界流可以在摄取所有数据后再进行计算. 有界流所有数据可以被排序,所以并不需要有序摄取. 有界流处理通常被称为批处理有界流,Fli ...
深刻理解Flink的有界流和无界流
先来看看有界流的代码: package com.mischen.it;import org.apache.flink.api.common.typeinfo.Types; import org.apa ...
flink介绍：有界流和无界流
日志:
一文了解Flink数据-有界数据与无界数据
在常规的数据处理中,我们最常访问的可能是来自于Mysql,文本等存储介质中的数据,对其进行计算分析.但是现在也越来越的出现流式计算的场景,对于某些时刻产生的数据能够进行实时性的分析.例如天猫双十一实时 ...
阻塞队列，有界队列，无界队列
在并发编程中,有时候需要使用线程安全的队列.如果要实现一个线程安全的队列有两种方式:一种是使用阻塞算法,另一种是使用非阻塞算法. 使用阻塞算法的队列可以用一个锁(入队和出队用同一把锁)或两个锁(入队和 ...
聊聊Java中的并发队列中有界队列和无界队列的区别
转载自 https://blog.csdn.net/AJ1101/article/details/81711812 本文主要总体的说一说各种并发队列首先来一张全体照从有界无界上分常见的有界 ...
「Flink实时数据分析系列」2. 流处理基本概念
来源 | 「Stream Processing with Apache Flink」作者 | Fabian Hueske and Vasiliki Kalavri 翻译 | 吴邪大数据4年从业经验 ...
Flink官方文档笔记13 流的分析的基本介绍
文章目录 Streaming Analytics Event Time and Watermarks 事件时间和水印机制 Working with Event Time 用Event Time解决问题 ...
大数据之无界数据流和有界数据流
无界流:有一个开始但是没有结束,不会在生成时终止并提供数据,必须连续处理无界流,也就是说必须在获取后立即处理event.对于无界数据流我们无法等待所有数据都到达,因为输入是无界的,并且在任何时间点都不 ...

Flink-有界流与无界流

什么是有界流和无界流？

Flink-有界流与无界流相关推荐

最新文章

热门文章