在数据分析和应用中，数据的时效性是一个绕不开的问题。离线数据和实时数据的区别是什么？在业务应用中，我们应该如何选择？许多业务产品或运营人员常常搞不清楚这两者的差异，总是...

flink对于流处理架构的意义十分重要，kafka让消息具有了持久化的能力，而处理数据，甚至穿越时间的能力都要靠flink来完成。在Streaming-大数据的未来一文中我们知道，对于流式处理最重要的两...

校对：丁楠雅作者：GETINDATA公司创始人兼大数据顾问彼得亚·雷克鲁斯基（Piotr Krewski）和GETINDATA公司首席执行官兼创始人亚当·卡瓦（Adam Kawa）目录内容简介设计理念HADOOP组件HDFSYARNYARN 应用程序...

快速掌握flink sql基础00前言Flink 作为一个统一的批流处理框架，其 Table API 和 SQL 是高层次的处理 API。尽管当前功能仍在积极开发中，但已经可以支持批流统一处理。Table API 允许在 Java 和 Scal...

本文主要探讨flink中的triggers。Trigger类接受两个泛型参数，一个是元素类型，另一个是窗口类型。它定义了onElement、onProcessingTime、onEventTime、canMerge、onMerge、clear等方法，其中onElement、onProcess...

设想我们要设计一个交易数据展示系统，实时呈现比特币最近1s钟的成交均价。我们可以通过交易数据接口以非常低的延迟获得全球各个比特币交易市场的每一笔比特币的成交价，成交额，交易...

此文选自google大神tyler akidau的另一篇文章：streaming 102: the world beyond batch欢迎回来！如果您错过了我以前的帖子，Streaming-大数据的未来，强烈建议您先花时间阅读那篇文章。简要回顾一下，上一...

越来越多的应用程序正在使用flink进行低延迟数据处理。flink通过一个计算引擎统一了批处理和流处理。然而，在实际操作中，为了真正实现批处理和流处理的统一，需要一个数据系统为这两种...