腾讯云产品

MySQL 的 CDC 源表，支持对 MySQL 数据库的全量和增量读取，并保证 Exactly Once 语义。MySQL CDC 底层使用了 Debezium 来实现对变更数据流的实时抓取（Change Data Capture）。

适用于一个作业需要同时引用多个外部 Catalog 的场景，但是由于多个 Hive/HDFS 配置文件会产生冲突，所以不支持同时使用多个需要这个配置文件支持的 Catalog （例如：Hive Catalog 、 Paimon(hive) Catalog)。

逻辑函数用来执行逻辑运算，结果是布尔值（Boolean）。逻辑状态有 TRUE、FALSE、UNKNOWN 三种（NULL 值的逻辑状态是 UNKNOWN），因而 NOT TRUE 不一定是 FALSE，还可能是 UNKNOWN。

消息队列 CMQ（Cloud Message Queue，以下简称 CMQ）是基于腾讯自研消息引擎的分布式消息队列系统，可以用作数据源（Source）和数据目的（Sink）。用户可以把流数据导入到 CMQ 的某个 Queue 中，通过 Flink 算子进行处理后，输出到相同或不同 CMQ 示例的另一个 Queue。

Doris 连接器通过 Stream Load 把上游变更事件写入 Apache Doris，支持自动建库建表、表结构变更同步以及自动分区表，通过 YAML 作业定义即可完成一条数据同步链路。

对流计算 Oceanus 作业，可以以进行4种操作：发布、运行、停止、创建副本，这些操作支持批量处理，这篇将对这4种操作进行概念解析与讲解。

用户可以使用 CREATE VIEW 语句创建视图。视图是一个虚拟表，基于某条 SELECT 语句。视图可以用在定义新的虚拟数据源（类型转换、列变换和虚拟列等），拆分过长代码等场景。

ClickHouse Sink Connector 提供了对 ClickHouse 数据仓库的写入支持。ClickHouse Source Connector 提供了 ClickHouse 作为批数据源和维表的功能。

为了让作业、数据探索等不同场景共用同一套库表元数据，避免在每个 Flink 作业里重复 `CREATE TABLE`，流计算 Oceanus 提供与独享集群、共享集群对等的元数据服务（HiveMetastore，以下简称 HMS），可在已有集群上一键开通，并通过下载的 `hive-hms-***.jar` (包含 hive-site.xml) 直接接入 Flink 作业的 HiveCatalog。

标识符用来唯一地表示表名或列名。当前流计算 Oceanus 中标识符的命名规则如下。