正在生成
详细信息:
检测到您已登录华为云国际站账号,为了您更好的体验,建议您访问国际站服务网站 https://www.huaweicloud.com/intl/zh-cn
不再显示此消息
DDL语法定义 CREATE TABLE语句 CREATE CATALOG语句 CREATE DATABASE语句 CREATE VIEW语句 CREATE FUNCTION语句 父主题: SQL语法约束与定义
Format Format概述 Avro Format Canal Format Confluent Avro Format CSV Format Debezium Format JSON Format Maxwell Format Ogg Format Orc Format Parquet
Doris Doris Connector概述 Doris源表 Doris结果表 Doris维表 父主题: Connector列表
FileSystem FileSystem源表 FileSystem结果表 父主题: Connector列表
Hbase HBase连接器支持读取和写入HBase集群。本文档介绍如何使用HBase连接器基于HBase进行SQL查询。 HBase连接器在upsert模式下运行,可以使用 DDL 中定义的主键与外部系统交换更新操作消息。但是主键只能基于HBase的rowkey字段定义。如果没
Redis Redis源表 Redis结果表 Redis维表 父主题: Connector列表
lateness_interval) 返回相对应的滚动窗口范围以外的上界时间戳。 示例 1. 根据订单信息使用kafka作为数据源表,JDBC作为数据结果表统计用户在30秒内的订单数量,并根据窗口的订单id和窗口开启时间作为主键,将结果实时统计到JDBC中: 根据MySQL和kafka所在的虚拟私有云
函数 自定义函数 自定义函数类型推导 自定义函数参数传递 内置函数 父主题: Flink Opensource SQL1.15语法参考
逻辑函数 表1 逻辑函数 SQL函数 返回类型 描述 boolean1 OR boolean2 BOOLEAN 如果 boolean1 为 TRUE 或 boolean2 为 TRUE 返回 TRUE。支持三值逻辑。 例如 true || Null(BOOLEAN) 返回 TRUE。
条件函数 函数说明 表1 条件函数 条件函数 函数说明 CASE value WHEN value1_1 [, value1_2 ]* THEN result1 [ WHEN value2_1 [, value2_2 ]* THEN result2 ]* [ ELSE resultZ
Hash函数 表1 Hash函数 Hash函数 函数说明 MD5(string) 以 32 个十六进制数字的字符串形式返回 string 的 MD5 哈希值;如果字符串为 NULL,则返回 NULL。 SHA1(string) 以 40 个十六进制数字的字符串形式返回 string
DWS DWS Connector概述 DWS源表(不推荐使用) DWS结果表(不推荐使用) DWS维表(不推荐使用) 父主题: Connector列表
产品咨询相关问题 使用咨询 作业管理 隐私安全
跨源连接相关问题 跨源连接问题 跨源分析问题 跨源连接运维报错
授权相关问题 使用咨询 运维指导
使用API相关问题 如何获取AK/SK? 如何获取项目ID? 提交SQL作业时,返回“unsupported media Type”信息 不同账号的调用API时的项目ID(Project ID)是固定的吗? 创建SQL作业的API执行超过时间限制,运行超时报错 API接口返回的中文字符为乱码,如何解决?
使用SDK相关问题 使用SDK查询SQL作业结果,如何设置超时时间? 服务器:请求dli.xxx,unable to resolve host address, 如何解决?
跨源连接问题 DLI增强型跨源连接为什么要创建对等连接 增强型跨源连接绑定队列失败 DLI增强型跨源连接DWS失败 创建跨源成功但测试网络连通性失败怎么办? 怎样配置DLI队列与数据源的网络连通? DLI创建跨源连接,进行绑定队列一直在创建中怎么办? 按需队列怎样绑定跨源链接? 如何打通DLI和数据源的网络?
Flink SQL作业相关问题 Flink SQL作业的消费能力如何,即一天可以处理多大的数据量? Flink SQL中的temp流中数据是否需要定期清理,如何清理? Flink SQL作业将OBS表映射为DLI的分区表 Flink SQL作业Kafka分区数增加或减少,不用停止Flink作业,实现动态感知
性能调优 Flink作业推荐配置指导 Flink作业如何进行性能调优 如何在一个Flink作业中将数据写入到不同的Elasticsearch集群中? Flink作业重启后,如何保证不丢失数据? 父主题: Flink作业相关问题