Flink源码

描述



内容


流媒体优先运行时，支持批处理和数据流程序

Java和Scala中优雅流畅的API

运行时支持非常高的吞吐量和低事件延迟的同时

基于数据流模型，支持DataStream API中的事件时间和无序处理

跨不同时间语义（事件时间，处理时间）的灵活窗口（时间，计数，会话，自定义触发器）

具有精确一次处理保证的容错能力

流媒体节目中的自然背压

用于图形处理（批处理），机器学习（批处理）和复杂事件处理（流式处理）的库

内置支持DataSet（批处理）API中的迭代程序（BSP）

自定义内存管理，可在内存和核外数据处理算法之间实现高效，可靠的切换

Apache Hadoop MapReduce和Apache Storm的兼容性层

与YARN，HDFS，HBase和Apache Hadoop生态系统的其他组件集成


代码下载：

链接: https://pan.baidu.com/s/1iBooyiHL58XxeyXxtvvaZA 密码: xqnp

源码地址：
https://github.com/apache/flink