Apache Flink Apache Flink是由Apache软件基金会开发的开源流处理框架其核心是用Java和Scala编写的分布式流数据流引擎Flink以数据并行和管道方式执行任意流数据程序Flink的流水线运行时系统可以执行批处理和流处理程序此外Flink的运行时本身也支持迭代算法的执行 Flink提供高吞吐量低延迟的流数据引擎以及对事件时间处理和状态管理的支持Flink应用程序在发生机器故障时具有容错能力并且支持exactlyonce语义程序可以用JavaScalaPython和SQL等语言编写并自动编译和优化到在集群或云环境中运行的数据流程序 Flink并不提供自己的数据存储系统但为Amazon KinesisApache KafkaAlluxioHDFSApache Cassandra和Elasticsearch等系统提供了数据源和接收器