使用方式如上，核心就是对SourceFunction的实现 FlinkKafkaConsumerBase FlinkKafkaConsumerBase继承RichPa ...

之前看 Flink Source 的 metrics 时候，看到 FlinkKafkaConsuemr 消费 Kafka 数据的代码，感觉比较有意思，就仔细看下了 大致流程如下： FlinkKafKaConsuemr 的启动流程就不细讲了，直接跳到 ...

Flink架构、原理与部署测试 Apache Flink是一个面向分布式数据流处理和批量数据处理的开源计算平台，它能够基于同一个Flink运行时，提供支持流处理和批处理两种类型应用的功能。 现有的开源计算方案，会把流处理和批处理作为两种不同的应用类型，因为它们所提供的SLA ...

Flink on Yarn 的两种模式 Yarn Session：启动一个长期运行的 Yarn 程序，这个 Yarn 程序在不同的 container 上启动 Job Manager 和 Task Manager，实现了 Flink 集群功能，然后每个 Flink app 都提交 ...

一. Flink的引入 这几年大数据的飞速发展，出现了很多热门的开源社区，其中著名的有 Hadoop、Storm，以及后来的 Spark，他们都有着各自专注的应用场景。Spark 掀开了内存计算的先河，也以内存为赌注，赢得了内存计算的飞速发展。Spark 的火热或多或少的掩盖 ...

DTFT变换的性质 线性性质 设 \[x[n]\xrightarrow{DTFT}X(e^{jw})\quad y[n]\xrightarrow{DTFT}Y(e^{jw})​ \] ...

队名：955 组长博客：https://www.cnblogs.com/cclong/p/11841141.html 作业博客：https://edu.cnblogs.com/campus/fzu/S ...

《HelloGitHub》第 08 期 兴趣是最好的老师，《HelloGitHub》就是帮你找到兴趣！ 简介 最开始我只是想把自己在浏览GitHub过程中，发现的有意思、高质量、容易上手的项目收集起来，这样便于以后查找和学习。后来一想，如果给这些GitHub项目都加上简单 ...