串流處理
串流處理（）是一種計算機編程範式，相當於數據流程編程，，和反應式編程 ，其允許一些應用更容易地利用了有限形式的並行處理。這些應用程序可以使用多個計算單元，例如圖形處理上的浮點運算器或現場可編程門陣列（FPGAs），而無需明確管理這些單元之間的分配，同步或通信。 串流處理範例通過限制可執行的並行計算來簡化並行軟件和硬件。給定一個數據序列（串流處理），一系列操作（內核函數）被應用到串流中的每個元素。例如：直播軟件。內核函數通常使用流水線(計…
标签：#串流處理
共 3 篇文章
Apache Flink
Apache Flink是由Apache软件基金会开发的开源流处理框架，其核心是用Java和Scala编写的分布式流数据流引擎。Flink以数据并行和管道方式执行任意流数据程序，Flink的流水线运行时系统可以执行批处理和流处理程序。此外，Flink的运行时本身也支持迭代算法的执行。 Flink提供高吞吐量、低延迟的流数据引擎以及对事件-时间处理和状态管理的支持。Flink应用程序在发生机器故障时具有容错能力，并且支持exactly-o…
Apache Storm
Storm是一个分布式计算框架，主要由Clojure编程语言编写。最初是由Nathan Marz及其团队创建于BackType，该项目在被Twitter取得后开源。它使用用户创建的“管（spouts）”和“螺栓（bolts）”来定义信息源和操作来允许批量、分布式处理流式数据。最初的版本发布于2011年9月17日。 Storm应用被设计成为一个拓扑结构，其接口创建一个转换“流”。它提供与MapReduce作业类似的功能，当遇到异常时该拓扑…