加载中
flinksql 自定义udf

1、pom.xml(注意:pom中有多余的jar,本人暂时未进行剔除)

2021/03/18 09:55
303
5、flinksql 表的查询转换

package com.jd.data; import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment; import org.apache.flink.table.api.DataTypes; import org.apache.flink.table.api...

2021/03/07 09:19
240
4、flinksql链接kafka

<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLo...

2021/03/07 00:09
276
3、flinksql 表(读取外部文件)

1、TableEnvironment 可以注册目录 Catalog, 可以基于catalog 注册表 2、表 是由一个标识符 来指定的, 由三部分组成:catalog、 数据库名、对象名 3、表可以是常规的,也可以是虚拟的(视图...

flink 窗口函数之增量聚合与全量聚合

flink 窗口函数后会跟进聚集函数,聚合函数又分为增量聚合与全量聚合 增量聚合:本时间窗口范围内的数据聚合 全量聚合:本次时间窗口聚合结果+ 历史聚合结果 聚合后生成新的历史聚合结果 pu...

2020/08/07 17:57
1.8K
kafka学习

场景驱动方式:kafka client: 生产者发送数据的流程 消费者消费数据的流程 server kafka的网络架构是如何设计的 kafka的数据是如何存储的 kafka的副本是如何同步的 kafka的元数据信息是如何...

2020/08/01 16:56
19
windows10 mysql 8 安装

今天帮同事安装 windows mysql 8 ; 基本上是一键安装,但是 安装完,赋权限啥的搞了半天,赋权限的语句和之前低版本的不一样了, 旧版本: GRANT ALL PRIVILEGES ON *.* TO 'root'@'%' IDEN...

raid 技术

磁盘访问接口分为:IDE、SATA、SCSI、USB,但是都比较慢,此时出现了raid技术(采用条带技术) raid级别: 0:条带 性能提升:读、写 冗余能力(容错能力):无 空间利用率:1 至少2块盘 1:...

2020/04/20 08:35
30
hive常用函数

1、coalesce(a, b,c) 返回 a b c 字段中第一个不是null的字段值,如果都为null 那么返回 null 2、split(str, regex) 将字符串切割成数组 order by : 全局排序 sort by : 一个reduce 内有序...

2018/04/03 17:52
41

没有更多内容

加载失败,请刷新页面

返回顶部
顶部