其对Flink的队列网段放通。参考测试地址连通性分别根据MySQL和Kafka的地址测试队列连通性。若能连通，则表示跨源已经绑定成功，否则表示未成功。 登录MySQL，并使用下述命令在flink库下创建orders表。 CREATE TABLE `flink`.`orders` (

查看更多 →

来自英文名称 逆向表数据 不逆向：逆向数据库时，将表导入到码表目录中，但是不导入表数据。您可以在完成逆向数据库后，参考填写数值到码表中添加记录到码表中。 覆盖：逆向数据库时，将表导入到码表目录中，同时将表数据导入到该码表中。 *数据表 选择一个或多个需导入的数据表。 图9 逆向配置

查看更多 →

错误信息写入指定的错误信息表error_table_name中。您可以通过以下SQL，查询详细错误信息。 1 openGauss=# SELECT * FROM error_table_name; 错误信息表结构如表1所示。 表1 错误信息表 列名称 类型 描述 nodeid integer

查看更多 →

创建RDS表 创建RDS/DWS表用于与输入流连接。 RDS的更多信息，请参见《关系型数据库用户指南》。 流表JOIN语法请参见流表JOIN。 前提条件 请务必确保您的账户下已在关系型数据库（RDS）里创建了PostgreSQL或MySQL类型的RDS实例。 如何创建RDS实例，

查看更多 →

创建源表 DataGen源表 DWS源表 Hbase源表 JDBC源表 Kafka源表 MySQL CDC源表 Postgres CDC源表 Redis源表 Upsert Kafka源表 父主题： 数据定义语句DDL

查看更多 →

错误信息写入指定的错误信息表error_table_name中。您可以通过以下SQL，查询详细错误信息。 1 openGauss=# SELECT * FROM error_table_name; 错误信息表结构如表1所示。 表1 错误信息表 列名称 类型 描述 nodeid integer

查看更多 →

的地址测试队列连通性。若能连通，则表示跨源已经绑定成功，否则表示未成功。 登录RDS MySQL，并使用下述命令在flink库下创建orders表，并插入数据。创建数据库的操作可以参考创建RDS数据库。 在flink数据库库下创建orders表： CREATE TABLE `flink`

查看更多 →

料表管理 用于管理料表，具体功能包含：从本地文件中导入产品料表，展示产品料表，校验产品料表，产品料表查询，工单料表查询。 导入方案 维护料表导入时的方案模板，以及模板下对应的明细行数据 前提条件：已登录MBM-F，且拥有该菜单栏目的操作权限 同样的方案编码和方案类型不能有重复的两条【发布】状态的数据

查看更多 →

参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 数据源类型，‘jdbc’表示使用JDBC connector，必须为jdbc connector.url 是 数据库的URL connector.table 是 读取数据库中的数据所在的表名 connector

查看更多 →

创建RDS表 创建RDS/DWS表用于与输入流连接。 RDS的更多信息，请参见《关系型数据库用户指南》。 流表JOIN语法请参见流表JOIN。 前提条件 请务必确保您的账户下已在关系型数据库（RDS）里创建了PostgreSQL或MySQL类型的RDS实例。 如何创建RDS实例，

查看更多 →

从Kafka源表中读取数据，将JDBC表作为维表，并将二者生成的表信息写入Kafka结果表中，其具体步骤如下： 参考增强型跨源连接，在 DLI 上根据MySQL和Kafka所在的虚拟私有云和子网分别创建相应的增强型跨源连接，并绑定所要使用的Flink弹性资源池。 设置MySQL和Kafk

查看更多 →

TRUNCATE 删除表 MySQL在使用TRUNCATE语句删除表数据时可以省略 "TABLE"关键字， GaussDB (DWS) 不支持这种用法。此外，DSC工具在做迁移TRUNCATE语句时会添加 "CONTINUE IDENTITY RESTRICT"关键字。 输入示例 1

查看更多 →

错误信息写入指定的错误信息表error_table_name中。您可以通过以下SQL，查询详细错误信息。 1 SELECT * FROM error_table_name; 错误信息表结构如表1所示。 表1 错误信息表 列名称 类型 描述 nodeid integer 报错节点编号。

查看更多 →

不更新：当码表已存在时，将直接跳过，不更新。 更新：当码表已存在时，更新已有的码表信息。如果码表处于“已发布”状态，码表更新后，您需要重新发布码表，才能使更新后的表生效。 在导入码表时，只有创建或更新操作，不会删除已有的码表。 上传模板 选择所需导入的码表文件。 导入后发布。 父主题：

查看更多 →

从Kafka源表中读取数据，将JDBC表作为维表，并将二者生成的表信息写入Kafka结果表中，其具体步骤如下： 参考增强型跨源连接，在DLI上根据MySQL和Kafka所在的虚拟私有云和子网分别创建相应的增强型跨源连接，并绑定所要使用的Flink弹性资源池。 设置MySQL和Kafk

查看更多 →

参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 数据源类型，‘jdbc’表示使用JDBC connector，必须为jdbc connector.url 是 数据库的URL connector.table 是 读取数据库中的数据所在的表名 connector

查看更多 →

关联子表 关联子表用于在当前表单中嵌套使用其他表单作为子表单，在提交当前表单数据同时创建子表的多条记录。 例如：提交一笔订单中包含了多个订单明细，则订单明细表为当前订单的子表。 在表单开发页面，从“高级组件”中拖拽“关联子表”组件至表单设计区域，如图1。 图1 关联子表 属性 字

查看更多 →

关联子表 关联子表用于在当前表单中嵌套使用其他表单作为子表单，在提交当前表单数据同时创建子表的多条记录。 例如：提交一笔订单中包含了多个订单明细，则订单明细表为当前订单的子表。 在表单开发页面，从“高级组件”中拖拽“关联子表”组件至表单设计区域，如图1。 图1 关联子表 属性 字

查看更多 →

创建源表 DataGen源表 DWS源表 Hbase源表 JDBC源表 Kafka源表 MySQL CDC源表 Postgres CDC源表 Redis源表 Upsert Kafka源表 FileSystem源表 父主题： 数据定义语句DDL

查看更多 →

参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 数据源类型，‘jdbc’表示使用JDBC connector，必须为jdbc connector.url 是 数据库的URL connector.table 是 读取数据库中的数据所在的表名 connector

查看更多 →

建同步任务”。 填写基本参数，参见表1。 表1 基本参数 参数名称 取值 计费模式 按需计费 区域 华北-北京四，确保RDS与DWS所选区域为同一个区域。 项目 华北-北京四 任务名称 DRS-DWS 描述 - 继续填写以下参数，参见表2。 表2 同步实例信息 参数名称 取值 数据流动方向

查看更多 →