检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
驱动类型 驱动类型选择Generic。 类名 类名 URL模板 DLI JDBC驱动连接的格式: DLI JDBC驱动连接配置示例请参考•DLIJDBC驱动连接的格式:和•DLIJDBC驱动连接配置示例:。 jdbc:dli://<endPoint>/projectId?
在批模式下,窗口表值函数的时间属性字段必须是 TIMESTAMP 或 TIMESTAMP_LTZ 类型的。 -- tables must have time attribute, e.g.
其中Array中的数据类型仅支持int、bigint、string、float、double。
参数描述 connector 是 无 String 读取表类型。
类型:队列类型选择“通用队列”。“按需计费”时需要勾选“专属资源模式”。 AZ策略、CPU架构、规格:保持默认即可。 企业项目:当前选择为“default”。 高级选项:选择“自定义”。 网段:配置队列网段。例如,当前配置为10.0.0.0/16。
其中Array中的数据类型仅支持int、bigint、string、float、double。
表1 创建Flink Jar对应的程序包主要参数说明 参数名称 说明 示例 包类型 支持的包类型如下: JAR:用户jar文件 PyFile:用户Python文件 File:用户文件 ModelFile:用户AI模型文件 JAR OBS路径 选择对应程序包的OBS路径。
connector.topic-urn' = '', 'connector.message-subject' = '', 'connector.message-column' = '' ); 参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 sink的类型
表1 异常响应说明 名称 参数类型 说明 error_code String 错误码,请参见表2。 error_msg String 错误详细信息。 错误码说明 当您调用API时,如果遇到“APIGW”开头的错误码,请参见API网关错误码进行处理。
返回值说明 返回DOUBLE类型的值。 示例代码 示例数据 为便于理解函数的使用方法,本文为您提供源数据,基于源数据提供函数相关示例。
登录数据湖探索管理控制台,选择“队列管理”,在对应“SQL队列”类型作业的“操作”列,单击“重启”。 在“重启队列”界面,选择“确定”完成队列重启。 使用UDF函数。
类型 选择创建的队列类型。 执行SQL作业请选择SQL队列。 执行Flink或Spark作业请选择通用队列。 执行引擎 SQL队列可以选择队列引擎为Spark或者HetuEngine。 企业项目 选择对应的企业项目。 单击“下一步”,配置队列的扩缩容策略。
类型:选择作业类型为:Flink OpenSource SQL。 名称:自定义。 图17 创建Flink作业 单击“确定”,进入作业编辑作业页面,具体SQL示例如下,部分参数值需要根据RDS和DMS对应的信息进行修改。
connector.version' = '1.4.3', 'connector.table-name' = '', 'connector.zookeeper.quorum' = '' ); 参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 connector的类型
connector.topic' = '', 'connector.properties.bootstrap.servers' = '', 'format.type' = '' ); 参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 connector类型
connector.type' = 'dis', 'connector.region' = '', 'connector.channel' = '', 'format.type' = '' ); 参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 数据源类型
connector.topic' = '', 'connector.properties.bootstrap.servers' = '', 'format.type' = '' ); 参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 connector类型
说明 connector 是 无 String connector类型,需配置为'postgres-cdc'。
SQL批处理类型的作业分别置于独立的弹性资源池中。
' = '', 'connector.driver' = '', 'connector.username' = '', 'connector.password' = '' ); 参数说明 表1 参数说明 参数 是否必选 说明 connector.type 是 数据源类型