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
:
