个人原创文章，禁止任何形式转载，否则追究法律责任！ 本文只发表在"公众号"和"博客园"，其他均属复制粘贴！如果觉得排版不清晰，请查看公众号文章。 话说看图看核心，代码也得看核心。Flink体系十分庞大复杂，没个几十篇文章没法聊完，核心就是最擅长，做的最好，就像说起百度 ...

前面说了Java8的流，这里还说流处理，既然是流，比如水流车流，肯定得有流的源头，源可以有多种，可以自建，也可以从应用端获取， 今天就拿非常经典的Kafka做源头来说事，比如要来一套应用日志实时分析 ...

Structured Streaming A stream is converted into a dynamic table. A continuous query is evaluated on the dynamic table yielding a new dynamic ...

大约各位看官君多少也听说了Storm/Spark/Flink，这些都是大数据流式处理框架。如果一条手机组装流水线上不同的人做不同的事，有的装电池，有的装屏幕，直到最后完成，这就是典型的流式处理。如果手机组装是先全部装完电池，再交给装屏幕的组，直到完成，这就是旧式的集合式处理。今天，就来先说 ...

实时流式计算 - Kafka Stream 2.1 概述 Kafka Stream是Apache Kafka从0.10版本引入的一个新Feature。它是提供了对存储于Kafka内的数据进行流式处理和分析的功能。 Kafka Stream的特点如下： Kafka Stream提供 ...

一手资料，完全来自官网，直接参考英文过来的，并加了一些自己的理解，希望能让看官君了解点什么，足矣。 环境：Flink1.9.1 难度：新手--战士--老兵--大师 目标： 理解Flink的计算模型 认识各重要组件 说明： 本篇作为前两篇的补充内容，算是理论篇 步骤 ...

运行结果 ...

流式计算的概念 实时获取来自不同数据源的海量数据，进行实时分析处理，获得有价值的信息，一般用于处理数据密集型应用。流式计算属于持续性、低时延、事件驱动型的计算作业。 流式计算工作原理 1.提交流式计算作业，流式计算作业属于常驻计算服务，必须预先定义好计算逻辑，并提交到流计算系统中 ...