问题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…
Java字节码增强应用
Java字节码增强技术 认识Instrumentation 基本用法: 方法 作用 addTra…
JVM Sandbox 源码分析(一)基础篇: Instrumentation和ClassFileTransformer作用
背景 jvm sandbox是一个开源项目https://github.com/alibaba/jvm-san…
Java类库设计之日志框架选择
Java日志框架现状 Java日志框架的故事说来话长,做过开发的一定遇到过slf4j,log4j,logbac…
Java多线程知识点(下)
26) 如何写代码来解决生产者消费者问题? 我们先尝试使用队列实现一个生产者和消费者模式。那么就需要先了解队列…
如何写代码来解决生产者消费者问题?
这个题目考验的实际上是线程间的通信和同步问题。我们再有一篇文章中,使用Object的wait和notify实现…