检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
DISTINCT FROM B BOOLEAN 若A与B不相等，则返回TRUE，将空值视为相同。 A IS NOT DISTINCT FROM B BOOLEAN 若A与B相等，则返回TRUE，将空值视为相同。 A BETWEEN [ASYMMETRIC | SYMMETRIC]
是 Boolean 执行请求是否成功。“true”表示请求执行成功。 message 是 String 系统提示信息，执行成功时，信息可能为空。 column_count 是 Integer 表的总列数。 columns 是 Array of Objects 表的列信息，包含列名称、类型和描述信息。具体参数详见表3。
流中的数据记录被解释为 UPSERT，也称为 INSERT/UPDATE，因为任何具有相同 key 的现有行都被覆盖。另外，value 为空的消息将会被视作为 DELETE 消息。 前提条件 该场景作业需要运行在DLI的独享队列上，因此要与kafka集群建立增强型跨源连接，且用户可以根据实际所需设置相应安全组规则。
sink，可以消费changelog 流。它会将INSERT/UPDATE_AFTER数据作为正常的Kafka消息写入，并将DELETE数据以value为空的Kafka消息写入（表示对应 key 的消息被删除）。Flink将根据主键列的值对数据进行分区，从而保证主键上的消息有序，因此同一主键上的更新/删除消息将落在同一分区中。
流中的数据记录被解释为 UPSERT，也称为 INSERT/UPDATE，因为任何具有相同 key 的现有行都被覆盖。另外，value 为空的消息将会被视作为 DELETE 消息。 前提条件 该场景作业需要运行在DLI的独享队列上，因此要与kafka集群建立增强型跨源连接，且用户可以根据实际所需设置相应安全组规则。
当字符串值为null时的存储形式，默认存成 "null" 字符串。 HBase的source的编解码将所有数据类型（除字符串外）将null值以空字节来存储。 krb_auth_name 否 无 String DLI侧创建的Kerberos类型的跨源认证名称。 数据类型映射 HBase
sink，可以消费changelog 流。它会将INSERT/UPDATE_AFTER数据作为正常的Kafka消息写入，并将DELETE数据以value为空的Kafka消息写入（表示对应 key 的消息被删除）。Flink将根据主键列的值对数据进行分区，从而保证主键上的消息有序，因此同一主键上的更新/删除消息将落在同一分区中。
当字符串值为null时的存储形式，默认存成 "null" 字符串。 HBase的source的编解码将所有数据类型（除字符串外）将null值以空字节来存储。 krb_auth_name 否 无 String DLI侧创建的Kerberos类型的跨源认证名称。 数据类型映射 HBase
当字符串值为null时的存储形式，默认存成 "null" 字符串。 HBase的source的编解码将所有数据类型（除字符串外）将null值以空字节来存储。 krb_auth_name 否 无 String DLI侧创建的Kerberos类型的跨源认证名称。 创建跨源认证 数据类型映射
也是必需的。 否则 Kafka 记录将使用空值作为键。 请参考Format页面以获取更多详细信息和格式参数。 key.fields 否 [] List<String> 表结构中用来配置消息键（Key）格式数据类型的字段列表。 默认情况下该列表为空，因此消息键没有定义。 列表格式为 'field1;field2'。
参数名称 描述 数据库名称 数据库名称只能包含数字、英文字母和下划线，但不能是纯数字，且不能以下划线开头。 数据库名称大小写不敏感且不能为空。 输入长度不能超过128个字符。 说明： “default”为内置数据库，不能创建名为“default”的数据库。 企业项目 如果所建队列属于企业项目，可选择对应的企业项目。
被覆盖。另外，value为空的消息将会被视作为DELETE消息。 作为sink，upsert-kafka连接器可以消费changelog流。它会将INSERT/UPDATE_AFTER数据作为正常的Kafka消息写入，并将DELETE数据以value为空的Kafka消息写入（表示对应
否 Boolean 请求执行是否成功。“true”表示请求执行成功。 message 否 String 系统提示信息，执行成功时，信息可能为空。 queue_name 否 String 新增队列的名称。 说明： 队列名称不区分大小写，系统会自动转换为小写。 请求示例 创建一个名称为
务运行情况界面。 说明： 新建队列，运行作业时会重新拉集群，大概需要10分钟左右才能拉好集群，在集群创建好之前单击SparkUI会导致缓存空的projectID，从而导致无法查看SparkUI。建议使用专属队列，集群不会被释放，就不会有该问题，或者提交作业后等一段时间再查看Spa
否 Boolean 请求执行是否成功。“true”表示请求执行成功。 message 否 String 系统提示信息，执行成功时，信息可能为空。 queues 否 Array of Object 队列信息。具体请参考表4。 表4 queues参数 参数名称 是否必选 参数类型 说明
否 Boolean 请求发送是否成功。“true”表示请求发送成功。 message 否 String 系统提示信息，执行成功时，信息可能为空。 job_id 否 String 此SQL将生成并提交一个新的作业，返回作业ID。用户可以使用作业ID来查询作业状态和获取作业结果。 job_mode
是 Boolean 执行请求是否成功。“true”表示请求执行成功。 message 是 String 系统提示信息，执行成功时，信息可能为空。 job_count 是 Integer 作业总个数。 jobs 是 Array of Objects 作业信息。具体参数请参见表4。 表4
is_success Boolean 执行请求是否成功。“true”表示请求执行成功。 message String 系统提示信息，执行成功时，信息可能为空。 count Integer 返回的模板个数。 templates Array of Objects 模板信息列表。请参考表4。 表4 templates参数说明
当字符串值为null时的存储形式，默认存成 "null" 字符串。 HBase sink的编解码将所有数据类型（除字符串外）为null值时以空字节来存储。 sink.buffer-flush.max-size 否 2mb MemorySize 每次写入请求缓存行的最大值。 它能提升
当字符串值为null时的存储形式，默认存成 "null" 字符串。 HBase sink的编解码将所有数据类型（除字符串外）为null值时以空字节来存储。 sink.buffer-flush.max-size 否 2mb MemorySize 每次写入请求缓存行的最大值。 它能提升
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
