Apache Flink Time & Window 深度解析
作者：邱从贤
1、 Window & Time 介绍
Apache Flink（以下简称 Flink） 是一个天然支持无限流数据处理的分布式计算框架，在 Flink 中 Window 可以将无限流切分成有限流，是处理有限流的核心组件，现在 Flink 中 Window 可以是时间驱动的（Time Window），也可以是数据驱动的（Count Window）。
下面的代码是在 Flink...
查看全文 >>
Apache Flink 漫谈系列(03) - Watermark
实际问题（乱序）
在介绍Watermark相关内容之前我们先抛出一个具体的问题，在实际的流式计算中数据到来的顺序对计算结果的正确性有至关重要的影响，比如：某数据源中的某些数据由于某种原因(如：网络原因，外部存储自身原因)会有5秒的延时，也就是在实际时间的第1秒产生的数据有可能在第5秒中产生的数据之后到来(比如到Window处理节点).选具体某个delay的元素来说，假设在一个5秒的Tumble窗...
查看全文 >>
零基础入门系列
零基础入门系列
Flink 零基础入门系列优质内容推荐如下：
| 《Apache Flink 零基础入门（一）：基础概念解析》| 《Apache Flink 零基础入门（二）：开发环境搭建和应用的配置、部署及运行》| 《Apache Flink 零基础入门（三）：DataStream API 编程》| 《Apache Flink 零基础入门（四）：客户端操作的 5 种模式》| 《Apache F...
查看全文 >>
Apache Flink SQL概览
本篇核心目标是让大家概要了解一个完整的Apache Flink SQL Job的组成部分，以及Apache Flink SQL所提供的核心算子的语义，最后会应用Tumble Window编写一个End-to-End的页面访问的统计示例。
Apache Flink SQL Job的组成
我们做任何数据计算都离不开读取原始数据，计算逻辑和写入计算结果数据三部分，当然基于Apache Flink SQ...
查看全文 >>
如何从小白进化成 Apache Flink 技术专家？9节基础课程免费公开！
随着数据量的爆发，AI走上风口，典型的大数据业务场景下数据业务最通用的做法是：选用批计算的技术处理全量数据，采用流计算的技术处理实时增量数据。在生产环境中，用户通常采用批处理和流处理两套计算引擎来支持这两种场景。弊端就是需要写两套代码，维护两套引擎，毫无疑问，这种架构带来了额外的负担与成本。
面对全量数据和增量数据，能否用一套统一的大数据引擎技术来处理？
Apache Flink 被业界公认为最...
查看全文 >>
Apache Flink 零基础入门（五）：流处理核心组件 Time&Window 深度解析
作者：邱从贤
1. Window & Time 介绍
Apache Flink（以下简称 Flink） 是一个天然支持无限流数据处理的分布式计算框架，在 Flink 中 Window 可以将无限流切分成有限流，是处理有限流的核心组件，现在 Flink 中 Window 可以是时间驱动的（Time Window），也可以是数据驱动的（Count Window）。
下面的代码是在 Flink...
查看全文 >>
Apache Flink 零基础入门（五）：流处理核心组件 Time&Window 深度解析
作者：邱从贤
1. Window & Time 介绍
Apache Flink（以下简称 Flink） 是一个天然支持无限流数据处理的分布式计算框架，在 Flink 中 Window 可以将无限流切分成有限流，是处理有限流的核心组件，现在 Flink 中 Window 可以是时间驱动的（Time Window），也可以是数据驱动的（Count Window）。
下面的代码是在 Flink...
查看全文 >>
The APR based Apache Tomcat Native library which allows optimal performance in production 问题的解决
信息:
The APR based Apache Tomcat Native library which allows optimal performance in production environments was not found on the java.library.path:XXXX
出现原因分析：
Tomcat建议使用apache的apr，来更好的运行Tomcat;
...
查看全文 >>
The APR based Apache Tomcat Native library which allows optimal performance in production 问题的解决
信息:
The APR based Apache Tomcat Native library which allows optimal performance in production environments was not found on the java.library.path:XXXX
出现原因分析：
Tomcat建议使用apache的apr，来更好的运行Tomcat;
...
查看全文 >>
Apache Beam的API设计
Apache Beam的API设计
Apache Beam还在开发之中，后续对应的API设计可能会有所变化，不过从当前版本来看，基于对数据处理领域对象的抽象，API的设计风格大量使用泛型来定义，具有很高的抽象级别。下面我们分别对感兴趣的的设计来详细说明。
Source
Source表示数据输入的抽象，在API定义上分成两大类：一类是面向数据批处理的，称为BoundedSource，它能够...
查看全文 >>
