【文件属性】:
文件名称:java8stream源码-Flink:测量Flink的性能并定制Yarn
文件大小:14.04MB
文件格式:ZIP
更新时间:2021-06-04 17:22:18
系统开源
java8流源码Apache
Flink
Apache
Flink
是一个开源的流处理框架,具有强大的流处理和批处理能力。
了解更多关于
Flink
的信息
特征
支持批处理和数据流程序的流优先运行时
Java
和
Scala
中优雅流畅的
API
同时支持非常高的吞吐量和低事件延迟的运行时
基于Dataflow
模型,支持
DataStream
API
中的事件时间和乱序处理
跨不同时间语义(事件时间、处理时间)的灵活窗口(时间、计数、会话、自定义触发器)
具有完全一次处理保证的容错
流媒体程序中的自然背压
图处理(批处理)、机器学习(批处理)和复杂事件处理(流)库
数据集(批处理)API
中对迭代程序
(BSP)
的内置支持
自定义内存管理,可在内存和核外数据处理算法之间进行高效、稳健的切换
Apache
Hadoop
MapReduce
和
Apache
Storm
的兼容层
与
YARN、HDFS、HBase
和
Apache
Hadoop
生态系统的其他组件集成
流媒体示例
case
class
WordWithCount
(
word
:
String
,
count
: