Apache Flink 是高效和分布式的通用数据处理平台。

Apache Flink 声明式的数据分析开源系统,结合了分布式 MapReduce 类平台的高效,灵活的编程和扩展性。同时在并行数据库发现查询优化方案。

要求

git clone HTTPS://Github.com/apache/incubaTor-flink.git
cd incubator-flink
mvn clean package -DskipTests # this will take up to 5 minutes

 

Apache Flink 1.4.0 发布,通用数据处理平台
Apache Flink 1.4.0 发布了。ApacheFlink 是一个开源的流处理框架,应用于分布式,高性能,始终可用的,准确的数据流应用程序。此版本更新内容:Sub-task[FLINK-3551] - Sync Scala and Java Streaming Examples[FLINK-3582] - Add Iterator over State for All Keys in Partitioned State[FLINK-5270] - Refactor the batc

发布于 2017-12-14 00:16:56 | 200 次阅读

Apache Flink 1.3.2 发布,通用数据处理平台
Apache Flink 社区发布了 Apache Flink 1.3 系列的第二个 bug 修复版本。此版本包含 60 多个修补程序和基于 Flink 1.3.1 的小小改进,官方表示强烈建议所有用户升级到 Flink 1.3.2。值得关注的变更:Flink Kafka Consumer 0.10 的默认 Kafka 版本从 0.10.0.1 升级到 0.10.2.1Flink Kinesis Consumer AWS API 调用行为

发布于 2017-08-06 00:55:29 | 153 次阅读

Apache Flink 1.3.1 发布,通用数据处理平台
Apache Flink 1.3.1 发布了,这是 Apache Flink 1.3 系列的首个 bug 修复版本。该版本包含 50 个修复程序和对 Flink 1.3.0 的小改进。下面的列表包括所有修补程序的详细列表。建议用户升级至该版本。详细更新如下:Bug[FLINK-6492] - Unclosed DataOutputViewStream in GenericArraySerializerConfigSnapshot#write()[

发布于 2017-06-23 23:51:40 | 159 次阅读

Apache Flink 1.3.0 发布,通用数据处理平台
Apache Flink 1.3.0 发布了,带来了 incremental checkpointing,Stream SQL 改进以及其他更多的更新内容。Apache Flink 是高效和分布式的通用数据处理平台。Apache Flink 声明式的数据分析开源系统,结合了分布式 MapReduce 类平台的高效,灵活的编程和扩展性。同时在并行数据库发现查询优化方案。在过去 4 个月里,Flink

发布于 2017-06-02 00:02:45 | 116 次阅读

Apache Flink 1.0.0 发布,通用数据处理平台
Apache Flink 1.0.0 发布了,Apache Flink 是高效和分布式的通用数据处理平台。Apache Flink 声明式的数据分析开源系统,结合了分布式 MapReduce 类平台的高效,灵活的编程和扩展性。同时在并行数据库发现查询优化方案。下载地址:Scala 2.10Scala 2.11Hadoop 1.2.1DownloadHadoop 2.3.0DownloadDownloadHadoop 2.4.1Downlo

发布于 2016-03-10 01:51:26 | 445 次阅读

Apache Flink 实现的数据流体系结构
data Artisans应用程序工程总监Jamie Grier最近在OSCON 2016 Conference大会发言谈到了使用Apache Flink构建的一种数据流体系结构。同时还谈到了数据流应用程序的构建块。数据流体系结构可用于处理随着时间流逝以事件流方式持续生成的数据,这一点不同于传统的静态数据集。相对于传统的集中式“状态化”数据库和数据仓库,

发布于 2016-06-14 00:17:21 | 145 次阅读


Copyright © 2007-2017 PHPERZ.COM All Rights Reserved   冀ICP备14009818号  版权声明  广告服务