本文源码基于flink1.14 平台用户在使用我们的flinkSql时经常会开启minaBatch来优化状态读写 所以从源码的角度具体解读一下miniBatch的原理 先看一下flinksql是如何触发miniBatch的优化的 主要就是这个Calcite的rule了，来具体看一下 ...

...

一、DataSet API之Data Sources（消费者之数据源） 介绍： flink提供了大量的已经实现好的source方法，你也可以自定义source 通过实现sourceFunction接口来自定义无并行度的source， 或者你也可以通过实现 ...

一、环境准备 本机环境：jdk11、scala2.12、maven3.6 新建一个maven项目，pom如下 项目结构如下 1、添加scala源文件，新建一个scala的文件夹， ...

同时写3个批处理，如果前2个批处理没有问题，最后一个有错误那么3个批处理都不会执行需要注意列如： use Materl GO select * from t_icitem GO inset into table (bid,char(10)) 这里insert写错了 GO ...

作用：想发送多条SQL，又要降低与数据库系统的交互，这时使用批处理 一】Statement对象——适合对不同结构的SQL语句进行批处理操作 步骤: 1）将给定的 SQL 命令添加到此 Statement 对象的当前命令列表中 ...

把hive 表stu77 的数据写入 mysql 表test_stu 中. 中间可以加自己的逻辑. ...

-----------更新说明---------- 突然就想水一篇博客，刚好说明一下这段时间基本没有更新的问题。 简单介绍下我的职业生涯，大家有留意的话，可以在博客园上看到，我的博客是从20 ...