logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

flink中的时间属性

1:时间的几种类型(官网概念)1.1处理时间指的是执行具体操作时的机器时间(大家熟知的绝对时间, 例如 Java的 System.currentTimeMillis()) )1.2事件事件指的是执行具体操作时的机器时间(大家熟知的绝对时间, 例如 Java的 System.currentTimeMillis()) )2:时间窗口flink提供了三种窗口函数分别是滚动窗口...

文章图片
#flink#大数据#big data
flink打宽数据的三种方式

1:首先要区分普通表和时态表1.1:普通表:可以理解为普通表就是一张随着时间数据在不断变化的表,类似于每个停车场内现存的车辆个数,他的最大特点是数据持续发生变化但是始终保持原有的条数,类似于总量总和,这个数据是不断的发生变化的,一般来讲这张表对应的是外部数据表例如:假设 LatestRates 是一个物化的最新汇率表 (比如:一张 HBase 表),LatestRates 总是表示 HBase 表

文章图片
#flink#大数据#big data
maven中<scope>参数</scope>的配置

参数名称具体功能<scope>compile</scope>默认值,表示当前依赖包要参与当前项目的编译后续测试运行时打包<scope>provided</scope>当前包只在编译和测试的时候使用,而不再后续的运行和打包的时候不会打包进来<scope>test</scope>表示当前依赖包只参与测试工作<scope&gt

文章图片
#maven#java
flinksql实时读取kafka写入mysql

因为flink版本迭代比较迅速,在我们进行代码的编写过程中容易出现版本不兼容的问题,为此本文是在flink版本为1.12.0的基础上完成开发的。1:配置maven依赖(重要)<?xml version="1.0" encoding="UTF-8"?><project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http:

文章图片
#kafka#mysql#java
linux文本编辑器的使用方式

1:行首 :%s/^/your_word/2:行尾 :%s/$/your_word/3:批量注释:ctrl+v 进入列编辑模式,向下或向上移动光标,把需要注释的行的开头标记起来,然后按大写的I,再插入注释符,比如"#",再按Esc,就会全部注释了。4:批量删除注释:v进入可视化模式然后shift+G回到最后全选再control+v选中第一行5:撤销上一次的操作:esc+u6:跳转到行首:shift

文章图片
#linux#运维#服务器
到底了