黑砂博客

flink1.14 sql基础语法（二） flink sql表定义详解 一、表的概念和类别 1.1 表的标识结构 每一个表的标识由 3 部分组成： catalog name...

假设有这样⼀种查询需求：终端⽤户只需要查询数据的汇总结果，不关⼼明细数据，并且数据的汇总条件是预先明确的（GROUP BY 条件明...

1、删除分区 CREATE TABLE test_partition1 (`id` String,`ctime` DateTime )ENGINE = MergeTree()PARTITION BY toYYYYMM(ctim...

应用程序使用KafkaConsumer向Kafka订阅主题，并从订阅的Topic上接收消息。 要想知道如何从Kafka读取消息，需要先了解消费者和消费者组的概念。 ...

目录 第3章 Hive数据类型 第 4 章 DDL 数据定义 第5章DML数据操作 第6章 查询（语法与MySQL一样） 第 7 章 分区表和分桶表 第 8 章 函数 第3章...

首先：打开win10的设置按钮，打开以后打开“更新和安全选项”，然后打开“恢复”按钮 正在上传…重新上传取消 就可以看到“重置此电脑”了&#...

StarRocks 3.0 版本介绍 StarRocks 3.0 版本是 StarRocks 发展历程中的一个重要里程碑，经过两年多的发展，StarRocks 发布了超过 80 个版本...

Lab1 硬件和安装 步骤一：准备计算机 任务： 使用Red Hat Linux光盘启动系统 在启动时进入BIOS界面 设置系统启动顺序为A，CDROM，C...

Spark内存迭代是每个task根据算子之间形成的DAG在内存中不断迭代计算的过程。 如图，带有分区的DAG以及阶段划分，可以从图中得到逻辑上最优的t...

概述 需求来源，在review前人留下的屎山代码时发现如下截图所示的代码片段： 也就是说代码是空实现的。 于是有此需求：消息重新消费。 ...