步骤一：创建SQL分析任务
本文介绍创建SQL分析任务的操作流程，以及SQL分析工作台的查询对象、SQL语句编写区域和操作栏的功能。前提条件 已购买物联网平台的企业版实例，具体操作，请参见 购买企业版实例。背景信息 您可以使用SQL分析工作台，配置SQL分析任务。更多...
SPL 块结构
无论程序是存储过程、函数、子程序还是触发器，SPL 程序都具有相同的块结构。一个块最多包含三个部分-可选的声明部分，必需的可执行部分以及可选的异常部分。...以下输出表明异常部分中的语句作为除以零的结果执行。An exception occurred
JSON支持
JSON支持SELECT和INSERT语句。但是Json format的支持并没有从根本上改变cql api的使用方式，CQL 需要的数据定义模型还是必须定义的。JSON format的使用只是提供了一种使用JSON方式的方法。Lindorm CQL支持将多个列的数据按照JSON的格式进行...
区分大小写
SPL程序中使用的关键字和用户定义的标识符不区分大小写。例如 DBMS_OUTPUT.PUT_LINE('Hello ...语句 DBMS_OUTPUT.PUT_LINE('Hello World!');生成以下输出：Hello World!但语句 DBMS_OUTPUT.PUT_LINE('HELLO WORLD!');生成输出：HELLO WORLD!
分支节点实现特定时间执行任务
节点（除了最后一天之外运行）正常执行 总结 使用分支节点要点如下：DataWorks捕获赋值节点的最后一条SELECT语句或者最后一行标准输出流，作为赋值节点的输出，供下游引用。分支节点的每一个输出都被关联了条件，下游挂分支节点作为上游，...
使用COPY命令导出Hologres的数据至OSS
本文指导您使用 copy to 命令语句和 hg_dump_to_oss 命令语句将查询的数据导出到指定的OSS。使用限制 仅当前Hologres实例的Superuser或拥有 pg_execute_server_program 权限的用户，才可以使用 hg_dump_to_oss 导出Hologres的数据至OSS。...
概述
无 通用 单实例SQL赋值 将SELECT语句读取的数据赋值给输出变量，输出变量可以在下一节点中被使用。配置SQL赋值节点 条件分支 条件分支节点可用于在任务流中进行条件判断。执行任务流时，如果条件分支节点的条件表达式判断结果为True，执行...
CREATE TABLE AS
表列具有与 SELECT 的输出列相关联的名称和数据类型（除非您可以通过给定新列名称的显式列表来覆盖列名称）。CREATE TABLE AS 与创建视图有一些相似之处，但确实很不一样：前者是创建一个新表，并仅对查询进行一次计算以最初填充新表。新表...
IF-THEN-ELSE IF
IF语句可嵌套，以便替代IF语句可在确定外部IF语句的条件是true还是false后调用。在以下示例中，外部 IF-THEN-ELSE 语句测试员工是否具有佣金。然后内部 IF-THEN-ELSE 语句测试员工的总薪酬是高于还是低于公司平均值。DECLARE v_empno emp....
日志分析（直接采集）
关键字查询 例如搜索包含关键字 error 的日志，查询语句为：{job="arms-agent",appId="a2n80plglh@89f2dd21b561bdc"}|="error"例如搜索 traceId 为 eaac105afb16540713955671006d0009 的日志，查询语句为：{job="arms-agent",appId="a2n80...
EXECUTE
本文介绍了EXECUTE的语法、参数等内容。简介 EXECUTE 被用来执行一个之前准备好的语句。由于预备语句只在会话期间存在，该预备语句必须在当前会话中由一个更早执行的 ...输出 EXECUTE 返回的命令标签是预备语句的命令标签而不是 EXECUTE。
平滑函数
示例1 查询分析语句：*|select ts_smooth_fir(stamp,value,'rectangle',4)from(select_time_-_time_%120 as stamp,avg(v)as value from log GROUP BY stamp order by stamp)输出结果：示例2 查询分析语句：*|select ts_smooth_fir(stamp,...
自然语言到SQL语言转义（基于大语言模型的NL2SQL）
PolarDB for AI推出自研的基于大语言模型的自然语言到数据库查询语言转义（Large Language Model based Nature Language to SQL，简称LLM-based NL2SQL）解决方案，PolarDB for AI会帮助用户将输入的自然语言转换为SQL语句。LLM-based NL2...
UDT概述
例如，不可以使用语句 group by new java.math.BigInteger('123')，但可以使用语句 group by new java.math.BigInteger('123').hashCode()。因为 hashCode 方法的返回值是 int.class 类型，可以当做内置类型INT来使用（应用上述内置类型与...
多路输出（MULTI INSERT）
MaxCompute SQL支持您在一条SQL语句中通过 insert into 或 insert overwrite 操作将数据插入不同的目标表或者分区中，实现多路输出。本文中的命令您可以在如下工具平台执行：MaxCompute客户端 使用SQL分析连接 使用云命令行（odpscmd）连接...
Flink_SQL任务开发方式
您无需重复编写DDL语句，无需进行繁杂的输入、输出、维表映射，从而简化开发，提升效率和体验。同时通过元表可以有效避免直接编写原生Flink DDL语句导致的敏感信息透出等问题。使用示例 若您需要创建 demo01 和 demo02 数据表，并将 demo01...
Flink_SQL任务开发方式
您无需重复编写DDL语句，无需进行繁杂的输入、输出、维表映射，从而简化开发，提升效率和体验。同时通过元表可以有效避免直接编写原生Flink DDL语句导致的敏感信息透出等问题。使用示例 若您需要创建 demo01 和 demo02 数据表，并将 demo01...
MULTI INSERT
MaxCompute SQL支持您在一条SQL语句中通过 insert into 或 insert overwrite 操作将数据插入不同的目标表或者分区中，实现多路输出。前提条件 执行操作前需要具备目标表的修改权限（Alter）及源表的元信息读取权限（Describe）。授权操作请...
ROLLUP的并行加速
您可以使用 ROLLUP 语法实现只借助一条查询语句，就计算出数据在不同维度上划分组之后得到的统计结果以及所有数据的总体值。本文将介绍如何使用 ROLLUP 语法。前提条件 PolarDB 集群版本需为 PolarDB MySQL版 8.0且Revision version为8.0.1...
SQL基本语法
本文为您介绍高级搜索中使用的SELECT查询语句的基本语法。查询语法 从数据库中检索数据的过程或命令称为查询。在SQL中，SELECT 命令用于指定查询。SELECT语句的基本语法如下：SELECT[DISTINCT]column1[AS column_name],column2,function ...
变量
例如，在脚本代码节点中增加输出变量，该输出变量可以在下游节点的SQL语句中被引用。单实例SQL赋值输出变量：通过该节点定义SQL查询的结果集，用该结果集充当二维矩阵，在变量定义过程中任意取出一个元素，或者基于任意一个行向量i、列向量...
创建数据流
单击 数据输出 节点，在页面下方的 数据输出 页签中配置数据输出节点。数据库：配置项 描述 数据库类型 选择输出数据的目标数据库类型。数据库 搜索并选择输出数据的目标数据库。说明 如果数据库未登录，在 登录实例 对话框中，输入 数据库...
如何优化数据导入导出
MySQL命令导入数据 程序导入数据 load data语句导入数据 Batch Tool工具导入数据（PolarDB-X 配套的导入导出工具）MySQL原生命令使用示例 mysql-e 命令可以连接本地或远程服务器，通过执行SQL语句，例如select方式获取数据，原始输出数据以...
配置SQL赋值节点
SQL赋值节点可以将SELECT语句读取的数据赋值给该节点的输出变量，输出变量可以在下一节点中作为输入变量被使用。本文介绍配置SQL赋值节点的方法。背景信息 SQL赋值节点赋予任务流获取表中数据作为下游节点的变量的能力。变量在任务节点中的...
步骤二：编写SQL分析语句
本文介绍编写SQL分析语句的操作流程。前提条件 已创建SQL分析任务：您需在SQL数据分析工作台，根据业务需求，编写SQL分析语句。背景信息 下列类型的数据存储表可作为SQL分析的查询对象，您可通过SQL分析语句来处理对应表的数据。平台系统表...
执行JS
1.组件介绍 说明 必要前置组件：打开新网页 或 获取已打开的网页 利用本组件支持操作Chrome、Edge、IE浏览器，在指定网页中，通过JavaScript脚本执行js操作。2.输入项 说明 请参照可视化编辑器内组件面板中各输入项的帮助信息 3.输出项 ...
使用介绍
reserved_count:每组保留的个数，负数为保留全部 sql:需要打散的sql语句 rankTvf 在打散过滤sql结果后，输出的结果仍保留原sql的顺序关系，但会删除被过滤掉的行。使用示例：select*from table(rankTvf('brand','-size','1',(SELECT brand,...
高温报警
本文以高温报警（传感器温度>80度时，输出报警信息到本地文件中）的场景为例，详细说明如何使用SQL进行流数据分析作业的编写以及流数据分析作业如何运作。流程图如下所示。前提条件 请您确保已创建边缘实例，具体操作请参见 专业版环境搭建...
自定义SQL
本文介绍自定义SQL算子的使用方法和注意事项。用途 当系统提供的内置算子无法满足需求时，用户...输出字段 配置该算子的输出字段，可手动编辑也可通过解析sql语句自动生成。自动解析的sql格式如图所示：这两个行将解析出如下两个字段信息：
配置Vertica输出组件
本文为您介绍如何配置Vertica输出组件。操作步骤 请参见 离线管道组件开发入口，进入离线单条管道脚本的开发页面。在离线单条管道脚本的开发页面，按照下图操作指引，进入 Vertica输出配置 对话框。在 Vertica输出配置 对话框，配置参数。...
配置Vertica输出组件
本文为您介绍如何配置Vertica输出组件。操作步骤 请参见 通过离线单条管道配置集成任务，进入离线单条管道脚本的开发页面。在离线单条管道脚本的开发页面，按照下图操作指引，进入 Vertica输出配置 对话框。在 Vertica输出配置 对话框，...
配置Teradata输出组件
本文为您介绍如何配置Teradata输出组件。前提条件 已创建Teradata数据源，如何创建，请参见 创建Tablestore数据源。进行Teradata输出组件属性配置的账号，需具备该数据源的同步读权限。如果没有权限，则需要申请数据源权限，详情请参见 ...
配置Teradata输出组件
本文为您介绍如何配置Teradata输出组件。前提条件 已创建Teradata数据源，如何创建，请参见 创建Tablestore数据源。进行Teradata输出组件属性配置的账号，需具备该数据源的同步读权限。如果没有权限，则需要申请数据源权限，详情请参见 ...
使用说明
输出的日志格式如下：日志输出时间,应用名称,traceId,RpcId,SQL 语句,执行结果（success/failed),执行耗时（ms）,连接建立时间,数据库执行时间,当前线程名 输出的日志示例如下：2018-01-0318:12:33.541,xxx,0a0fe91c1514974353459100919649...
配置Oracle输出组件
Oracle输出组件用于向Oracle数据源写入数据。同步其他数据源的数据至Oracle数据源的场景中，完成源数据的信息配置后，需要配置Oracle输出组件的目标数据源。本文为您介绍如何配置Oracle输出组件。操作步骤 请参见 离线管道组件开发入口，...
配置Oracle输出组件
Oracle输出组件用于向Oracle数据源写入数据。同步其他数据源的数据至Oracle数据源的场景中，完成源数据的信息配置后，需要配置Oracle输出组件的目标数据源。本文为您介绍如何配置Oracle输出组件。操作步骤 请参见 离线管道组件开发入口，...
聚合函数
函数 函数输出类型 描述 count(expr)Bigint 返回SELECT语句检索的行中非NULL值的数量。结果为一个Bigint值。sum(expr)返回类型与expr类型一致 返回expr字段的和。如果查询结果为空，则返回NULL。avg(expr)Double 返回expr字段的平均值。...
Zeppelin概述
您还可以在Zeppelin可视化流式数据，Flink支持以下三种流式数据的可视化：Single模式 Single模式适合当输出结果是一行的情况，不适用图形化的方式展现。例如下面的 Select 语句。这条SQL语句只有一行数据，但这行数据会持续不断的更新。...
配置PostgreSQL输出组件
本文为您介绍如何配置PostgreSQL输出组件。操作步骤 请参见 离线管道组件开发入口，进入离线单条管道脚本的开发页面。在离线单条管道脚本的开发页面，按照下图操作指引，进入 PostgreSQL输出配置 对话框。在 PostgreSQL输出配置 对话框，...
配置PostgreSQL输出组件
本文为您介绍如何配置PostgreSQL输出组件。操作步骤 请参见 通过离线单条管道配置集成任务，进入离线单条管道脚本的开发页面。在离线单条管道脚本的开发页面，按照下图操作指引，进入 PostgreSQL输出配置 对话框。在 PostgreSQL输出配置 ...
- 产品推荐
- 这些文档可能帮助您