enjoy coding...
flink部署【高可用】 flink部署【高可用】
多机部署Flink standalone 集群部署前要注意的要点 每台机器上配置好java以及JAVA_HOME环境变量 最好挑选一台机器,和其他机器ssh 打通 每台机器上部署的Flink binary的目录要保证是同一个目录 如果需要用
2020-06-09
flink部署【使用k8s部署】 flink部署【使用k8s部署】
准备k8s环境准备相关YAML flink-configuration-configmap.yaml apiVersion: v1 kind: ConfigMap metadata: name: flink-config labels:
2020-06-09
flinkSQL-client初体验 flinkSQL-client初体验
概述本章创建一个模拟数据源将模拟数据源源不断写到kafka中,然后使用Flink SQL client查询kafka中的数据。 模拟数据由java对象序列化而成的json格式字符串,包含book的id、type、price和时间。 Book
2020-03-26
FlinkSQL中窗口函数 FlinkSQL中窗口函数
滚动窗口(TUMBLE)滚动窗口(TUMBLE)将每个元素分配到一个指定大小的窗口中。通常滚动窗口有一个固定的大小,并且不会出现重叠。例如:如果指定了一个5分钟大小的滚动窗口,无限流的数据会根据时间划分成[0:00 - 0:05)、[0:0
2020-03-26
flink时间属性 flink时间属性
时间属性Flink支持三种与流数据处理相关的时间概念:Processing Time、Event Time和Ingestion Time。 Flink SQL仅支持其中的两种时间类型Event Time和Processing Time:
2020-03-26
flinkSQL用户自定义函数(UDX) flinkSQL用户自定义函数(UDX)
UDX分类参考 UDX分类 描述 UDF(User Defined Function) 用户自定义标量函数(User Defined Scalar Function)。其输入与输出是一对一的关系,即读入一行数据,写出一条输出值。
2020-03-25
1 / 3