检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
Debezium Format 功能描述 Debezium是一个 CDC（Changelog Data Capture，变更数据捕获）的工具，可以把其他数据库的更改实时流式传输到 Kafka 中。
message 否 String 系统提示信息，执行成功时，信息可能为空。 job_id 否 String 此SQL将生成并提交一个新的作业，返回作业ID。用户可以使用作业ID来查询作业状态和获取作业结果。
表1 UDTF开发环境 准备项 说明 操作系统 Windows系统，支持Windows7以上版本。 安装JDK JDK使用1.8版本。 安装和配置IntelliJ IDEA IntelliJ IDEA为进行应用开发的工具，版本要求使用2019.1或其他兼容版本。
source、pattern、start_position、occurrence或return_option值为NULL时，返回NULL 示例代码 返回6。 select regexp_instr('a1b2c3d4', '[0-9]', 3, 2); 返回NULL。
当用户设置“feature”为“basic”时，该参数生效。用户可通过与“feature”参数配合使用，指定作业运行使用的DLI基础Flink镜像的版本 log_enabled=True, # 是否开启作业日志。
编写代码示例 public class WeightedAvgAccum { public long sum = 0; public int count = 0; } import org.apache.flink.table.functions.AggregateFunction
完整样例代码和依赖包说明请参考：Python SDK概述。
编写代码示例 public class WeightedAvgAccum { public long sum = 0; public int count = 0; } import org.apache.flink.table.functions.AggregateFunction
在自定义函数代码中，通过FunctionContext#getJobParameter获取map的各项内容，代码示例如下： context.getJobParameter("url","jdbc:mysql://xx.xx.xx.xx:3306/table"); context.getJobParameter
在自定义函数代码中，通过FunctionContext#getJobParameter获取map的各项内容，代码示例如下： context.getJobParameter("url","jdbc:mysql://xx.xx.xx.xx:3306/table"); context.getJobParameter
createDLITable方法创建DLI表 Table table = database.createDLITable(DLITblName, desc, columns, sortColumns); System.out.println(table); return
编写代码示例 public class WeightedAvgAccum { public long sum = 0; public int count = 0; } import org.apache.flink.table.functions.AggregateFunction
当所选择队列的剩余容量不能满足作业需求时，系统会自动扩容，将按照增加的容量计费。当队列空闲时，系统也会自动缩容。 Flink版本 具体参数说明如下： 1.10：具体SQL语法参考Flink OpenSource SQL1.10语法。
DLI JDBC Driver支持的API列表 DLI JDBC Driver支持JDBC标准的众多API，也有部分API不支持用户调用，例如涉及事务调用的API“prepareCall”，调用这类API将抛出“SQLFeatureNotSupportedException”异常。
DLI JDBC Driver支持的API列表 DLI JDBC Driver支持JDBC标准的众多API，也有部分API不支持用户调用，例如涉及事务调用的API“prepareCall”，调用这类API将抛出“SQLFeatureNotSupportedException”异常。
示例代码 1 2 3 4 5 6 7 def get_bucket_name(full_path): try: url = urlparse(full_path) return url.hostname except Exception
当用户设置“feature”为“basic”时，该参数生效 .withObsBucket("YourObsBucketName") // OBS桶名。
预留关键字 表1罗列了系统预留的关键字，以及它们在其他SQL标准中是否为预留关键字。如果需要使用这些关键字作为标识符，请加注双引号。
华东-上海二 项目 每个区域默认对应一个项目，由系统预置。 系统默认项目 名称 弹性资源池名称。 dli_resource_pool 规格 选择弹性资源池规格。 标准版 CU范围 弹性资源池最大最小CU范围。 64-64 网段 规划弹性资源池所属的网段。
message String 系统提示信息，执行成功时，信息可能为空。 执行失败时，用于显示执行失败的原因。 sqls Array of Object 样例模板信息，具体参数说明请参见表3。 sqlCount Integer 样例模板个数。
