检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
检测到您已登录华为云国际站账号，为了您更好的体验，建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
message 否 String 系统提示信息，执行成功时，信息可能为空。 job_id 否 String 此SQL将生成并提交一个新的作业，返回作业ID。用户可以使用作业ID来查询作业状态和获取作业结果。
Debezium Format 功能描述 Debezium是一个 CDC（Changelog Data Capture，变更数据捕获）的工具，可以把其他数据库的更改实时流式传输到 Kafka 中。
表1 UDTF开发环境 准备项 说明 操作系统 Windows系统，支持Windows7以上版本。 安装JDK JDK使用1.8版本。 安装和配置IntelliJ IDEA IntelliJ IDEA为进行应用开发的工具，版本要求使用2019.1或其他兼容版本。
return_option指定匹配的子串在source中的开始或结束位置。 如果pattern为空串，返回报错。 start_position或occurrence非BIGINT类型或小于等于0时，返回报错。
当用户设置“feature”为“basic”时，该参数生效。用户可通过与“feature”参数配合使用，指定作业运行使用的DLI基础Flink镜像的版本 log_enabled=True, # 是否开启作业日志。
* @param context */ @Override public void open(FunctionContext context) {} /** * 自定义逻辑 * @param s * @return
*/ public int eval(String s) { return s.hashCode() * factor; } /** * 可选 */ @Override public void close() {} }
dli_client = DliClient(auth_mode=auth_mode, region=region, project_id=project_id,ak=ak, sk=sk) return dli_client 参数说明与获取方式 参数说明 ak：账号 Access
password); LOG.info("connect successfully"); } catch (Exception e) { LOG.error(String.valueOf(e)); } return
password); LOG.info("connect successfully"); } catch (Exception e) { LOG.error(String.valueOf(e)); } return
*/ public int eval(String s) { return s.hashCode() * factor; } /** * 可选 */ @Override public void close() {} }
createDLITable方法创建DLI表 Table table = database.createDLITable(DLITblName, desc, columns, sortColumns); System.out.println(table); return
当所选择队列的剩余容量不能满足作业需求时，系统会自动扩容，将按照增加的容量计费。当队列空闲时，系统也会自动缩容。 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”异常。
当用户设置“feature”为“custom”时，该参数生效。用户可通过与“feature”参数配合使用，指定作业运行使用自定义的Spark镜像。关于如何使用自定义镜像，请参考《数据湖探索用户指南》。
预留关键字 表1罗列了系统预留的关键字，以及它们在其他SQL标准中是否为预留关键字。如果需要使用这些关键字作为标识符，请加注双引号。
message String 系统提示信息，执行成功时，信息可能为空。 执行失败时，用于显示执行失败的原因。 sqls Array of Object 样例模板信息，具体参数说明请参见表3。 sqlCount Integer 样例模板个数。
当用户设置“feature”为“basic”时，该参数生效 .withObsBucket("YourObsBucketName") // OBS桶名。
华东-上海二 项目 每个区域默认对应一个项目，由系统预置。 系统默认项目 名称 弹性资源池名称。 dli_resource_pool 规格 选择弹性资源池规格。 标准版 CU范围 弹性资源池最大最小CU范围。 64-64 网段 规划弹性资源池所属的网段。
长按/截图保存，微信识别二维码
或者关注公众号“华为云”
