分享

Flink源码


描述

1.png

内容


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

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


本帖被以下淘专辑推荐:

没找到任何评论,期待你打破沉寂

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

关闭

推荐上一条 /2 下一条