小版本升级
修复Lindorm SQL中Date类型和Time类型的时区问题。修复稳定性问题。2.2.17 2021年12月17日 功能优化 修复Lindorm SQL的BUG。优化冷存储Region的上线速度，使用冷存储的用户，建议将宽表引擎版本升级至2.2.17以上。2.2.16 2021年11月12日 ...
SQL诊断
基于慢Query日志的数据，Hologres提供SQL诊断的能力，通过对不同维度的趋势、明细分析，可以辅助您了解实例的使用情况并做相应的优化，以达到更好的效果。本文为您介绍如何使用SQL诊断。功能介绍与建议 当前SQL诊断支持的诊断内容如下：...
CREATE TABLE AS（CTAS）语句
本文为您介绍CREATE TABLE AS（CTAS）的使用方法，并提供了多种使用场景下的示例。前提条件 执行CTAS语法前，确保工作空间中已注册目标端的Catalog。详情请参见 管理元数据。使用限制 仅Flink计算引擎vvr-4.0.11-flink-1.13及以上版本支持...
DMS作业调度
您可以切换至RDS PostgreSQL数据库的SQL编辑页签查看数据库。在下方编辑框中，粘贴以下SQL：DROP FOREIGN TABLE IF EXISTS oss_${mydate};CREATE FOREIGN TABLE IF NOT EXISTS oss_${mydate}(a int,b int,c date)SERVER ossserver OPTIONS...
在Hue WebUI使用编辑器
本文以EMR-4.9.0版本为例，为您介绍如何在Hue WebUI中使用Hive编辑器和Spark SQL编辑器。前提条件 已设置安全组访问。重要 设置安全组规则时要针对有限的IP范围。禁止在配置的时候对0.0.0.0/0开放规则。已打开8888端口。使用Spark SQL编辑...
任务编排之电商打标
本文使用任务编排中的 单实例SQL赋值节点、条件分支节点 和单实例SQL节点，在数据库层面实现该需求。前提条件 您需要准备一个数据库，且拥有该数据库的变更权限。如需申请权限，请参见 DMS访问控制权限概述。环境准备 登录 数据管理DMS 5.0...
自定义函数
本文介绍了自定义函数的执行原理及使用方法。原理介绍 创建成功的自定义函数，会被持久化到Meta center中，按需加载到计算节点中执行。SQL相关的执行逻辑会发送到SQL engine中执行，然后获取执行结果，控制流程等相关的逻辑会在PL engine中...
文章相似度
文章相似度是在字符串相似度的基础上，基于词，计算两两文章或者句子之间的相似度，其中文章或句子需要以空格分割...Designer预置了多种算法组件，你可以根据不同的使用场景选择合适的组件进行数据处理，详情请参见 组件参考：所有组件汇总。
DML操作常见问题
MaxCompute SQL中使用到新数据类型（TINYINT、SMALLINT、INT、FLOAT、VARCHAR、TIMESTAMP或BINARY）时，需要执行如下语句开启新数据类型开关：Session级别：如果使用新数据类型，您需要在SQL语句前加上 set odps.sql.type.system.odps2=...
Python SDK示例：SQL
本文为您介绍Python SDK中执行SQL命令相关的典型场景操作示例。注意事项 PyODPS支持MaxCompute SQL查询，并可以读取执行的结果，使用时有以下注意事项。入口对象的 execute_sql('statement')和 run_sql('statement')方法可以执行SQL语句，...
自定义SQL
本文介绍自定义SQL算子的使用方法和注意事项。用途 当系统提供的内置算子无法满足需求时，用户可以通过编写SQL语句实现自己特定的业务逻辑。适用场景 计算链路 计算引擎 是否支持 离线 MaxCompute 是 Hive 是 HiveStorage 是 RDS/MySQL 是 ...
JSON函数和操作符
本文描述了用于处理和创建JSON数据的函数和运算器，以及SQL/JSON路径语言。处理和创建JSON数据 json和jsonb操作符表展示了可以用于JSON数据类型的操作符。此外，比较操作符表所示的常用比较操作符也适用于 jsonb，但不适用于 json。比较...
2021-03-16版本
VVR 3.0.0版本重大功能变更 支持在SQL JOIN中使用 Hints 语法。Kafka的Avro格式支持用户自定义Schema。支持Kafka、DataHub、SLS和MQ获取元消息列。优化Mysql-CDC功能：支持多种方式启动位点，包括binlog position、timestamp、earliest-...
宽表引擎版本说明
修复Lindorm SQL中Date类型和Time类型的时区问题。修复稳定性问题。2.2.17 2021年12月17日 功能优化 修复Lindorm SQL的BUG。优化冷存储Region的上线速度，使用冷存储的用户，建议将宽表引擎版本升级至2.2.17以上。2.2.16 2021年11月12日 ...
分区和列操作
具备修改表权限（Alter）的用户 本文中的命令您可以在如下工具平台执行：MaxCompute客户端 使用SQL分析连接 使用云命令行（odpscmd）连接 使用DataWorks连接 MaxCompute Studio 删除分区 为已存在的分区表删除分区。修改分区的更新时间 ...
2020年
新功能 MaxCompute支持通过SQL语言定义函数（SQL Function）在SQL脚本中使用SQL定义的UDF。UDF（SQL自定义函数）2020-07-23 新增代码嵌入式UDF。新功能 MaxCompute支持通过代码嵌入式UDF（Embedded UDF）将Java或Python代码嵌入SQL脚本。...
最大连通子图
最大连通子图算法用于识别无向图中最大的连通部分，即图中最大的节点集合，其中任意两节点间都可通过路径相连。该算法常用于网络分析、图像处理等领域。它通过深度优先搜索（DFS）或广度优先搜索（BFS）来遍历图，识别所有连通组件，再从中...
CREATE DATABASE AS（CDAS）语句
本文为您介绍CREATE DATABASE AS（CDAS）的使用方法，并提供了多种使用场景下的示例。背景信息 CDAS是 CTAS 语法的一个语法糖，用于实现整库同步、多表同步的功能。阿里云Flink引擎会将CDAS语句中每个需要同步的表翻译成一个对应的CTAS语句...
MaxCompute分区表数据导入
DataWorks作业案例 日常工作中往往需要周期性的调度以上的SQL，此时可以借助DataWorks的强大调度和作业编排能力，实现周期性调度，且使用一个调度作业覆盖以上两个场景。请仔细阅读以下内容，便于您 使用迁移工具导入DataWorks作业 时按照...
从Flink SQL导入
Flink全托管为您提供了丰富的SQL代码模板和数据同步模板，每种模板都为您提供了使用场景、代码示例和使用指导。您也可以直接单击对应的模板进行使用，快速实现您的业务逻辑，详情请参见 代码模板 和 数据同步模板。单击 下一步。在 新建...
使用介绍
自定义函数TVF相关使用说明。rankTvf rankTvf 主要是为了提供类sql窗口函数rank的功能，用于打散后过滤，其原型如下：...其原型如下：enableShuffleTvf((sql))使用方法：select*from table(enableShuffleTvf((SELECT brand,size FROM phone)))
Hologres SQL语句的常见问题
报错：DISTINCT is not implemented for window functions 问题原因：Hologres目前不支持在窗口函数中使用DISTINCT关键字。解决方法：窗口函数中去掉DISTINCT。报错：ERROR:commit ddl phase1 failed:DDLWrite is not allowed on replica ...
ALTER TABLE
使用示例-创建一个分区表 create table if not exists sale_detail(shop_name STRING,customer_id STRING,total_price DOUBLE)partitioned by(sale_date STRING,region STRING);修改表格的cluster属性 alter table sale_detail clustered ...
使用说明
示例代码 删除表、创建表和获取Metadata 说明 如果项目中使用了JDBC依赖，则不需要指定SDK依赖，设置了JDBC依赖后，会自动引入SDK。否则程序可能会因为版本不统一导致运行报错。import java.sql.Connection;import java.sql....
PyODPS查看一级分区
使用PyODPS查看一级分区。登录 DataWorks控制台。在左侧导航栏，单击 工作空间列表。选择 操作 列中的 快速进入>数据开发。在 数据开发 页面，右键单击已经创建的业务流程，选择 新建节点>MaxCompute>PyODPS 2。输入 节点名称，单击 确认。...
使用mysqldump导入导出数据
mysqldump并不会导出 PolarDB-X 中的Sequence对象，所以如果在源 PolarDB-X 中使用了Sequence对象，并且需要在目标 PolarDB-X 中继续使用相同的Sequence对象，则需要手动在目标 PolarDB-X 中创建同名的Sequence的对象。具体步骤如下：在源 ...
EXISTS
exists 是一个函数，用于显示变长数组或嵌套表的指定元素是否存在。如果集合的第n个元素存在，则 exists(n)返回TRUE，否则返回FALSE。如果n超出范围，exists 将返回FALSE，而不是引发预定义异常 SUBSCRIPT_OUTSIDE_LIMIT。对于已删除的元素...
子查询（SUBQUERY）
本文为您介绍MaxCompute支持的子查询的定义与使用方法。功能介绍 子查询指在一个完整的查询语句之中，嵌套若干个不同功能的小查询，从而一起完成复杂查询的一种编写形式。MaxCompute支持的子查询包含如下几种：基础子查询 基础子查询是在...
CREATE SCHEMA
CREATE SCHEMA 输入一个新模式到当前数据库中。简介 CREATE SCHEMA 输入一个新模式到当前数据库中。该模式名必须与当前数据库中任何现有模式的名称不同。一个模式本质上是一个名字空间：它包含命令对象（表、数据类型、函数以及操作符），...
树深度
您可以使用SQL脚本组件进行PAI命令调用，详情请参见 场景4：在SQL脚本组件中执行PAI命令。PAI-name TreeDepth-project algo_public-DinputEdgeTableName=TreeDepth_func_test_edge-DfromVertexCol=flow_out_id-DtoVertexCol=flow_in_id-...
计数三角形
您可以使用SQL脚本组件进行PAI命令调用，详情请参见 场景4：在SQL脚本组件中执行PAI命令。PAI-name TriangleCount-project algo_public-DinputEdgeTableName=TriangleCount_func_test_edge-DfromVertexCol=flow_out_id-DtoVertexCol=flow_...
基于Go database/sql接口的应用开发
本文介绍通过Go语言的database/sql包使用SQL开发Lindorm宽表应用的方法和示例。前提条件 已下载并安装 Go环境，建议安装Go 1.17及以上版本。已将客户端IP地址添加至Lindorm实例的白名单中，具体操作，请参见 设置白名单。使用限制 本文操作...
自动SQL限流
对于SQL模板限流，如果SQL中包含模板ID信息，会优先使用ID类信息，比如使用数据库中间件根据模板自动生成的SQL ID或者开发人员在SQL模板中添加的HINT信息。使用ID的优点是容易保证模板唯一，不会对其它模板的SQL造成影响，缺点是同样的SQL...
k-Core
您可以使用SQL脚本组件进行PAI命令调用，详情请参见 场景4：在SQL脚本组件中执行PAI命令。PAI-name KCore-project algo_public-DinputEdgeTableName=KCore_func_test_edge-DfromVertexCol=flow_out_id-DtoVertexCol=flow_in_id-...
子查询（SUBQUERY）
本文为您介绍MaxCompute支持的子查询的定义与使用方法。功能介绍 子查询指在一个完整的查询语句之中，嵌套若干个不同功能的小查询，从而一起完成复杂查询的一种编写形式。MaxCompute支持的子查询包含如下几种：基础子查询 IN SUBQUERY NOT ...
使用Go语言database/sql接口的应用开发
本文介绍通过Go语言的database/sql包使用SQL开发Lindorm宽表应用的方法和示例。前提条件 已下载并安装 Go环境，建议安装Go 1.17及以上版本。已将客户端IP地址添加至Lindorm实例的白名单中，具体操作，请参见 设置白名单。使用限制 本文操作...
社区版CDC
flink-1.13 release-2.2 vvr-4.0.15-flink-1.13～vvr-6.0.2-flink-1.15 release-2.3 vvr-6.0.2-flink-1.15～vvr-8.0.5-flink-1.17 release-2.4 vvr-8.0.1-flink-1.17~vvr-8.0.5-flink-1.17 release-3.0 社区版CDC连接器使用方法 SQL作业 ...
时序引擎版本说明
修复在PrepareStatement语句中使用Limit不支持Long类型的问题。修复存储锁住后无法手动删除数据的问题。修复SQL接口（api/v2/sql）对于长链接连续发起查询操作造成SQL执行异常的问题。修复TTL设置为0不生效的问题。3.4.14 2022年04月25日 ...
错误码
建议使用 SHOW PROCESSLIST 命令查看正在执行的SQL语句会话ID，并只针对返回的ID执行 KILL 命令。PXC-4006 ERR_TABLE_NOT_EXIST 描述：PolarDB-X 数据表不存在。示例：ERR-CODE:[PXC-4006][ERR_TABLE_NOT_EXIST]Table '*' doesn't exist....
Delta Lake 快速开始一
delta=spark.read.format("delta").load(deltaPath)events_delta.printSchema()重置数据库%pyspark spark.sql("DROP DATABASE IF EXISTS {} CASCADE".format(database))#注意{}是在pyspark里spark.sql()中使用的变量，参数在.format中指定...
- 产品推荐
- 这些文档可能帮助您