第一章 整体介绍1.1 什么是 Table API 和 Flink SQLFlink本身是批流统一的处理框架，所以Table API和SQL，就是批流统一的上层处理API。 目前功能尚未完善，处于活跃的开发阶段。 Table API是一套内

隐式转换的一些总结1.普通隐式转换/** * @author Jinxin Li * @create 2020-10-28 18:50 * 编译器在编译时,有可能编译不通过 * 尝试在作用域范围内查找可以让程序编译通过的逻辑 *

广播变量的使用,高可用的配置,监控系统的使用,反压等flink现象处理,大规模数据处理调优思想与实践

Yarn中如何调整AppMatser容器与Container容器的大小配置1.配置AppMatser容器大小的文件目录地址 AppMaster: hadoop3.1/etc/hadoop/capacity-scheduler.xml 2

1.Hive架构的理解我们只知道Hive是一个数据分析引擎,与HAOOP配合工作,但是对于小白来说,架构具体结构却了解不够清楚,本文将会对此进行一个解析 graph TD A[Hive/Driver]--Hive直接访问-->B[JDBC]

1.Kafka概述Kafka是一个分布式的基于发布/订阅模式的消息队列（Message Queue），主要应用于大数据实时处理领域。 1.1 消息队列与其应用场景发布/订阅模式 一对多，消费者消费数据之后不会清除消息 消息生产者（发布）将消