12篇文章 · 8638字 · 1人关注
独立集群提交 yarn session yarn single job
Event Time 事件事件 Processing Time 处理事件 Ingestion Time 摄取事件
dataSource 数据来源 sockect 自定义数据源不能并行的自定义数据眼 /** * 不能并行的自定义数据源 ...
DataSet 开发概述 DataSource 数据来源 readTextFile 计数器 Sink 分布式缓存 Transformation算...
前提条件1.)配置Java环境2.)配置Hadoop集群环境 下载flink包 # 下载步骤 1~3 1 https://flink...
一、状态分类 相对于其他流计算框架,Flink 一个比较重要的特性就是其支持有状态计算。即你可以将中间的计算结果进行保存,并提供给后续的计算使用...
Window是Flink的核心功能之一,使用好Window对解决一些业务场景是非常有帮助的。今天分享5个Flink Window的使用小技巧,不...
valueState<> 用于保存单个值 ListState<> 用于保存list元素 MapState<> 用于保存一组键值对 Reducin...
文集作者