shengjk1

LV1
发表了文章

一文搞定 Flink Job 的运行过程

之前我们知道了Flink 是如何生成 StreamGraph 以及 如何生成 job 和 如何生成Task,现在我们通过 Flink Shell 将他们串起来,...

shengjk1
发表了文章

大数据架构如何做到流批一体?

阿里妹导读:大数据与现有的科技手段结合,对大多数产业而言都能产生巨大的经济及社会价值。这也是当下许多企业,在大数据上深耕的原因。大数据分析场景需要解决哪些技术挑...

shengjk1
发表了文章

如何生成一个可信的Cookie

因为Cookie都是服务器端创建的,所以,生成一个可信Cookie的关键在于,客户端无法伪造出Cookie。

shengjk1
发表了文章

一文搞懂Flink SQL执行过程

学习了 apache calcite,基本上把 apache calcite 的官网看了一遍,也写了几个小例子,现在该分析一下 Flink SQL 的执行过程了...

shengjk1
发表了文章

Kafka中的HW、LEO、LSO等分别代表什么?

HW 、 LEO 等概念和上一篇文章所说的 ISR有着紧密的关系,如果不了解 ISR 可以先看下ISR相关的介绍。

shengjk1
发表了文章

java deep vs shallow copies

讨论 deep copy and shallow copy时,需要明白一点,肯定不是基本数据类型也不是 String,因为它们都是不可变的,都是值传递。换句话说...

shengjk1
发表了文章

calcite 入门

最近越来越明白了一件事:框架之所以叫框架,必然用到了模板方法,我们只需要实现哪些我们自己需要实现的东西即可。

shengjk1
发表了文章

JavaFx-TableView

shengjk1
发表了文章

JavaFx-Button

.button1 { -fx-font: 22 arial; -fx-base: #b6e7c9; }

shengjk1
发表了文章

JavaFx-Label

shengjk1
发表了文章

JavaFX-简单的登录界面

shengjk1
发表了文章

一文搞懂 FlinkSQL函数 LAST_VALUE 的原理

刚开始接触 FlinkSQL 时,对 LAST_VALUE 特别好奇,虽然工作当中有在用到,但还是特别的想知道它是怎么实现的,今天终于可以总结一下

shengjk1
发表了文章

一文搞懂 FlinkSQL 的 KafkaSource

前面我们了解了 写给大忙人看的Flink 消费 Kafka,今天我们一起来看一下 FlinkSQL Kafka 是如何与 Flink Streaming Kaf...

shengjk1
发表了文章

Flink 提交作业运行的各种模式总结

关于 Flink 的 Application Mode 自己还比较陌生,像 -d 等参数自己也不熟悉,决定好好总结一下,基于 Flink-1.12.x

shengjk1
发表了文章

FlinkSQL 平台

由于公司内部需求较多,并不想每次都写一个 streaming 程序,故而开始搭建 flinksql 平台,基于 jdk1.8,flink1.12.x

shengjk1
发表了文章

Flink 计算 TopN

使用 flink 很长一段时间了,突然发现竟然没有计算过 topN,这可是 flink 常见的计算场景了, 故自己想了一个场景来计算一下。 基于 Flink ...

shengjk1
发表了文章

Flink 计算 PV UV

使用 flink 很长一段时间了,突然发现竟然没有计算过 pv uv,这可是 flink 常见的计算场景了,面试时也是常问题之一。故自己想了一个场景来计算一下。...

shengjk1
发表了文章

一文搞懂 Flink 中的锁

之前在介绍 flink timer 的时候( 一文搞懂 Flink Timer ) 官网有这样的一句话

shengjk1
发表了文章

一文搞懂 flink 处理水印全过程

前面,我们已经学过了 一文搞懂 Flink 处理 Barrier 全过程,今天我们一起来看一下 flink 是如何处理水印的,以 Flink 消费 kafka ...

shengjk1
发表了文章

一文搞懂 Flink Stream Join原理

然后调用 Where 类的 equalTo 方法,保证了 stream1 stream2 相同的 key 进入到同一个窗口

shengjk1

个人简介

个人成就

扫码关注云+社区

领取腾讯云代金券