Flink 并行度设置 时间: 2021-07-15 | 分类: Flink | 字数: 970 字 | 阅读约: 2分钟 Flink 并行度设置 一个Flink程序由多个Operator组成(source、transformation和 sink)。 一个Operator由多个 阅读全文 »
Flink Time 时间: 2021-07-14 | 分类: Flink | 字数: 3620 字 | 阅读约: 8分钟 Flink Time 1.1 Time 在Flink的流式处理中,会涉及到时间的不同概念,如下图所示: EventTime[事件时间] 事件发生的时间,例如:点击网站上的某个链 阅读全文 »
Flink 窗口机制 时间: 2021-07-13 | 分类: Flink | 字数: 2657 字 | 阅读约: 6分钟 Flink 窗口机制 Flink Window 背景 Flink认为Batch是Streaming的一个特例,因此Flink底层引擎是一个流式引擎,在上面实现了流处理和批处理 阅读全文 »
Flink 常用API详解 时间: 2021-07-12 | 分类: Flink | 字数: 2557 字 | 阅读约: 6分钟 Flink 常用API详解 示例代码: https://gitee.com/ixinglan/flink-demo.git 第 1 节 Flink DataStream常用API DataStream API主要分为3块:DataSource、Transformation、 阅读全文 »
Flink 安装和部署 时间: 2021-07-11 | 分类: Flink | 字数: 586 字 | 阅读约: 2分钟 Flink 安装和部署 Flink支持多种安装模式 local(本地):单机模式,一般本地开发调试使用 StandAlone 独立模式:Flink自带集群,自己管理资源调度,生 阅读全文 »