过年被病毒闹的出不了门，就顺带着把flink秒级统计的逻辑写了一下，逻辑很简单，就是从kafka消费数据，然后…
flink
flink使用时间戳作为起始offset消费kafka的问题
代码如下 private static voidtest2()throwsException { En…
flink通过jdbc读取postgresql数据库里的数据
问题1： 从postgresql里使用flink-jdbc读取数据的问题, 数据类型不匹配，不支持jsonb等…
flink相关 – 通过Table API写入ElasticSearch的部分源码分析
New ElasticSearch()…xxx…registerTableSink(); ElasticS…
flink的动态表格
目的： 订阅kafka的消息(kafka的消息是从postgresql来的)，将kafka的消息作为Table…
flink相关 – 读入kafka数据源
业务代码如下 : fsTableEnv.connect( newKafka() …
flink学习笔记(一)
架构 什么是flink flink是一个框架或者叫流式计算引擎，他可以用来处理有界(批处理，mapReduc…