文章 2019-01-28 来自:开发者社区

终于等到你!阿里正式向 Apache Flink 贡献 Blink 源码

阿里妹导读:如同我们去年12月在 Flink Forward China 峰会所约,阿里巴巴内部 Flink 版本 Blink 将于 2019 年 1 月底正式开源。今天,我们终于等到了这一刻。 阿里资深技术专家大沙,将为大家详细介绍本次开源的Blink主要功能和优化点,希望与业界同仁共同携手,推动Flink社区进一步发展。 Blink简介 Apache Flink是德国柏林工业大学的几个博士生....

文章 2019-01-14 来自:开发者社区

Apache Flink 漫谈系列(15) - DataStream Connectors之Kafka

聊什么 为了满足本系列读者的需求,在完成《Apache Flink 漫谈系列(14) - DataStream Connectors》之前,我先介绍一下Kafka在Apache Flink中的使用。所以本篇以一个简单的示例,向大家介绍在Apache Flink中如何使用Kafka。 Kafka 简介 Apache Kafka是一个分布式发布-订阅消息传递系统。 它最初由LinkedIn公司开发,....

文章 2019-01-08 来自:开发者社区

Apache Flink 漫谈系列(13) - Table API 概述

什么是Table API 在《Apache Flink 漫谈系列(08) - SQL概览》中我们概要的向大家介绍了什么是好SQL,SQL和Table API是Apache Flink中的同一层次的API抽象,如下图所示: Apache Flink 针对不同的用户场景提供了三层用户API,最下层ProcessFunction API可以对State,Timer等复杂机制进行有效的控制,但用户使用的....

文章 2019-01-05 来自:开发者社区

Apache Flink,流计算?不仅仅是流计算!

作者:王峰(花名:莫问) 2018年12月下旬,由阿里巴巴集团主办的Flink Forward China在北京国家会议中心举行。Flink Forward是由Apache软件基金会授权的全球范围内的Flink技术大会,2015年开始在德国柏林举办,今年第一次进入中国。 今天,计算平台事业部的资深技术专家莫问,将带领我们重温这场大数据技术的饕餮盛宴,感受Apache Flink 作为下一代大数据....

Apache Flink,流计算?不仅仅是流计算!
文章 2019-01-01 来自:开发者社区

Apache Flink 漫谈系列(12) - Time Interval(Time-windowed) JOIN

说什么 JOIN 算子是数据处理的核心算子,前面我们在《Apache Flink 漫谈系列(09) - JOIN 算子》介绍了UnBounded的双流JOIN,在《Apache Flink 漫谈系列(10) - JOIN LATERAL》介绍了单流与UDTF的JOIN操作,在《Apache Flink 漫谈系列(11) - Temporal Table JOIN》又介绍了单流与版本表的JOIN,....

文章 2018-12-22 来自:开发者社区

超燃!Apache Flink 全球顶级盛会强势来袭[视频+PPT]

超燃!Apache Flink 全球顶级盛会强势来袭 摘要: 12月20日,北京国家会议中心。Flink Forward China 2018 强势来袭~ 【主会】 内容 《如何更好的参与贡献Apache Flink 项目》  Craig L Russell Secretary,The Apache Software Foundation 《主题演讲》周靖人 阿里巴巴集团 副总裁 ...

文章 2018-12-21 来自:开发者社区

【apache flink forward china 2018】中国一线公司上万台Flink机器应运

).阿里巴巴,腾讯,美团,爱奇艺,字节跳动(抖音,头条),等一线公司上万台flink机器应用 ).一线公司已升级大数据计算引擎Flink ).公布阿里巴巴将于2019年1月左右推出阿里的flink版本批流一体计算,包括阿里在Flink中的一些升级操作 Apache Flink Forward china 2018 :  https://github.com/opensourc....

文章 2018-12-15 来自:开发者社区

Apache Flink 漫谈系列(11) - Temporal Table JOIN

什么是Temporal Table 在《Apache Flink 漫谈系列 - JOIN LATERAL》中提到了Temporal Table JOIN,本篇就向大家详细介绍什么是Temporal Table JOIN。在ANSI-SQL 2011 中提出了Temporal 的概念,Oracle,SQLServer,DB2等大的数据库厂商也先后实现了这个标准。Temporal Table...

问答 2018-12-14 来自:开发者社区

Apache Flink:自定义触发器意外行为

Apache Flink:自定义触发器意外行为我有一个DataStream,它由一个事件组成,该事件具有一个表示一批生成元素的属性。该属性,我们称之为'batchNumber',在我从同一生产批次中摄取的每个事件中都是恒定的。我每批收到多个事件。 我想在'batchNumber'更改时分析批处理中的机器性能。我的方法是使用全局流并使用'batchNumber'作为密钥对其进行分区。我希望这会将全....

问答 2018-12-13 来自:开发者社区

Apache Flink - 启用连接排序

我注意到Apache Flink没有优化表连接的顺序。目前,它保留了用户指定的连接顺序(基本上,它按字面顺序进行查询)。我想Apache Calcite可以优化连接的顺序,但由于某些原因,这些规则在Apache Flink中没有使用。 例如,如果我们有两个表' R '和' S ' private val tableEnv: BatchTableEnvironment = TableEnviron....

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

Apache Spark 中国技术社区

阿里巴巴开源大数据技术团队成立 Apache Spark 中国技术社区,定期推送精彩案例,问答区数个 Spark 技术同学每日在线答疑,只为营造 Spark 技术交流氛围,欢迎加入!

+关注
相关镜像