代码模板
创建临时视图 如果您需要在Flink SQL开发过程中，重用代码，组织长查询或者SQL脚本来简化开发，则可以使用临时视图。INSERT INTO 如果您需要将查询结果写入到外部存储系统中的表，从而提供给下游应用程序，则可以使用INSERT INTO语法。...
SQL优化
数据库自治服务DAS提供SQL优化功能，自动输出诊断结果、优化建议和预期优化收益，您可以根据诊断结果确认是否采纳建议。本文介绍如何使用SQL优化功能。前提条件 数据库引擎为：RDS MySQL 自建MySQL MyBase MySQL MongoDB RDS PostgreSQL ...
高性能
云数据库RDS提供高性能实例，包括参数优化、SQL优化建议等优点。参数优化 RDS的所有参数都经过阿里云数据库行业专家多年的生产实践和优化。在RDS实例的生命周期内，DBA持续对其进行优化，确保RDS实例一直基于最佳配置运行。SQL优化建议 ...
概述
当前Flink SQL已经可以帮助您支持各种流计算场景。为了满足开发迭代需求或业务发展需求，SQL作业也需要不断变更，否则修改SQL作业后，并使用原来的状态数据重启作业，会出现状态不兼容的问题。从vvr-4.0.11-flink-1.13版本开始，Flink全...
高性能计算优化型实例概述
高性能计算优化型实例规格族hpc8ae 高性能计算优化型实例规格族hpc7ip 高性能计算优化型实例规格族hpc6id 高性能计算优化型实例介绍 高性能计算优化型实例（以下简称HPC优化实例）是专为提升HPC工作负载性能，同时优化大规模运行成本而打造...
从Flink SQL导入
本文介绍如何使用Flink SQL方式将Flink中的数据写入 云数据库ClickHouse。使用限制 只有Flink计算引擎VVR 3.0.2及以上版本支持使用Flink SQL写入 云数据库ClickHouse。前提条件 已在 云数据库ClickHouse 中创建表。更多信息，请参见 创建表...
作业调试
登录 实时计算控制台。在 Flink全托管 页签，单击目标工作空间 操作 列下的 控制台。在左侧导航栏上，单击 Session管理。单击 创建Session集群。填写配置信息。参数详情如下表所示。模块 配置项 说明 基础配置 名称 Session集群名称。部署...
步骤四：开发FLINK_SQL实时任务
本文将指导您完成本教程的FLINK_SQL实时任务的创建与开发。步骤一：新建 FLINK_SQL 任务 在Dataphin首页，单击顶部菜单栏 研发。按照下图操作指引，进入 新建FLINK_SQL任务 对话框。在 新建FLINK_SQL任务 对话框，配置参数。参数 说明 任务...
步骤四：开发FLINK_SQL实时任务
本文将指导您完成本教程的FLINK_SQL实时任务的创建与开发。步骤一：新建 FLINK_SQL 任务 在Dataphin首页，单击顶部菜单栏 研发。按照下图操作指引，进入 新建FLINK_SQL任务 对话框。在 新建FLINK_SQL任务 对话框，配置参数。参数 说明 任务...
管理AnalyticDB MySQL（ADB）Catalog
AnalyticDB MySQL Catalog提供的表可以直接作为Flink SQL作业中的AnalyticDB 3.0维表和AnalyticDB 3.0结果表。本文将从以下方面为您介绍如何管理AnalyticDB MySQL Catalog：创建AnalyticDB MySQL Catalog 查看AnalyticDB MySQL Catalog ...
2023年
2023年05月（V2.0.0.5）类别 功能 功能描述 相关文档 优化 SQL执行性能 SQL多并发执行时，提升单条SQL的执行性能，缩短总体执行时间。无 SQL并发度 优化单条SQL的内存使用，提升SQL总体并发度。无 ANALYZE ANALYZE收集统计信息功能优化。...
MongoDB（公测中）
实时计算Flink VVR 8.0.6及以上版本支持通过 CREATE TABLE AS（CTAS）语句 或 CREATE DATABASE AS（CDAS）语句 将MongoDB的数据和Schema变更同步到下游表。使用时需开启MongoDB数据库的前像后像（Pre-and Post-images）记录功能，详情请...
数据同步模版
您可以使用数据同步模版帮您快速生成数据同步的Flink SQL作业代码。本文为您介绍如何使用多库多表同步或者分库分表合并模版实现数据同步。背景信息 Flink全托管支持多库多表同步和分库分表合并两种数据同步方式，二者的区别请参见下表。...
JSON
Flink SQL类型 JSON类型 CHAR/VARCHAR/STRING string BOOLEAN boolean BINARY/VARBINARY string with encoding:base64 DECIMAL number TINYINT number SMALLINT number INT number BIGINT number FLOAT number DOUBLE number DATE string ...
CSV
Flink SQL类型 CSV类型 CHAR/VARCHAR/STRING string BOOLEAN boolean BINARY/VARBINARY string with encoding:base64 DECIMAL number TINYINT number SMALLINT number INT number BIGINT number FLOAT number DOUBLE number DATE string ...
自定义标量函数（UDSF）
Flink SQL作业开发。详情请参见 作业开发。获取ASI_UDSF_Source表中a字段中每行字符串中第2~4位的字符，代码示例如下。CREATE TEMPORARY TABLE ASI_UDSF_Source(a VARCHAR,b INT,c INT)WITH('connector'='datagen');CREATE TEMPORARY TABLE...
管理MaxCompute Catalog
背景信息 MaxCompute Catalog通过查询MaxCompute服务来获取MaxCompute中已存储物理表的Schema信息，您无需在Flink SQL中声明MaxCompute连接表的Schema便可以获取具体的字段信息。MaxCompute Catalog具有以下功能特点：MaxCompute Catalog中...
Canal
在很多情况下，利用Canal这个特性非常的有用，例如：将增量数据从数据库同步到其他系统 日志审计 数据库的实时物化视图 数据库表的temporal join变更历史 Flink还支持将Flink SQL中的INSERT、UPDATE或DELETE消息编码为Canal格式的JSON消息...
管理域名
在实时计算控制台上，您可以管理上下游服务的域名。本文为您介绍如何在实时计算控制台上新增域名、修改域名和删除域名。使用限制 填写域名时，不支持填写大写字符。单个工作空间最多只能设置50个合法域名。当工作空间状态为运行中时，才...
自定义表值函数（UDTF）
Flink SQL作业开发。详情请参见 作业开发。ASI_UDTF_Source表中每行字符串的message字段与字符串aa按照竖线（|）连接之后，按照竖线（|）分割成多列，代码示例如下。CREATE TEMPORARY TABLE ASI_UDTF_Source(`message` VARCHAR)WITH('...
管理MongoDB Catalog（公测中）
背景信息 MongoDB Catalog通过自动解析Bson文档来推导集合的Schema，您无需在Flink SQL中声明MongoDB集合的Schema便可以获取具体字段信息。MongoDB Catalog具有以下功能特点：MongoDB Catalog的表名对应MongoDB集合名，无需再通过DDL语句...
使用Flink写入数据（Transaction Table2.0）
MaxCompute与实时计算Flink版的字段类型对照关系如下。Flink 数据类型 MaxCompute 数据类型 CHAR(p)CHAR(p)VARCHAR(p)VARCHAR(p)STRING STRING BOOLEAN BOOLEAN TINYINT TINYINT SMALLINT SMALLINT INT INT BIGINT LONG FLOAT FLOAT DOUBLE...
自定义聚合函数（UDAF）
Flink SQL作业开发。详情请参见 作业开发。获取ASI_UDAF_Source表中a字段以b字段为权重的值，代码示例如下。CREATE TEMPORARY TABLE ASI_UDAF_Source(a BIGINT,b BIGINT)WITH('connector'='datagen');CREATE TEMPORARY TABLE ASI_UDAF_Sink...
基本概念
本文汇总使用弹性高性能计算E-HPC过程中涉及的基本概念，方便您查询和了解相关概念。使用弹性高性能计算涉及的相关概念如下表所示。概念 说明 集群 集群指运行高性能计算的节点集合，可以提供单节点不能提供的强大计算能力，拥有高性能、...
Dataphin使用Flink脚本任务运行报SQL语法错误
问题描述 Dataphin使用Flink脚本任务运行报SQL语法错误。解决方案 Dataphin Flink SQL中不支持DDL建表语法，CREATE建表需要使用创建元表的方式代替。适用于 Dataphin
自定义标量函数（UDSF）
Flink SQL作业开发。详情请参见 作业开发。获取ASI_UDSF_Source表中a字段中每行字符串中第2~4位的字符，代码示例如下。CREATE TEMPORARY TABLE ASI_UDSF_Source(a VARCHAR,b INT,c INT)WITH('connector'='datagen');CREATE TEMPORARY TABLE...
节点类型说明
Flink SQL Flink 流式节点，运行于Flink云计算资源之上，支持对RDS MySQL、Table Store、Hive、Kafka、Hbase、Phoenix、AnalyticDB MySQL和DataHub等类型的数据进行处理。Flink Vvr SQL Flink Vvr 流式节点，运行于Flink Vvr云计算资源之上...
管理MySQL Catalog
MySQL Catalog提供的表可以直接作为Flink SQL作业中的MySQL CDC源表、MySQL结果表和MySQL维表。支持RDS MySQL、PolarDB MySQL或自建MySQL。支持直接访问分库分表逻辑表。支持配合CDAS和CTAS语法完成基于MySQL数据源的整库同步、分库分表...
自治中心
相关功能：异常检测 SQL限流 自动SQL限流 自动SQL优化 自动性能扩展 自动空间扩展 空间碎片自动回收 SQL请求行为识别 操作步骤 登录 DAS控制台。在左侧导航栏中，单击 实例监控。找到目标实例，单击实例ID，进入目标实例详情页。在左侧导航...
Queries语句
EXPR$0|EXPR$1|+-+-+|Hello World|It's me|+-+-+1 row in set Flink SQL支持在字符串常量中包含unicode值，您可以通过以下方式声明：使用反斜杠作为默认转义符 SELECT U&'\263A' 使用自定义符号作为转义符 SELECT U&'#263A' UESCAPE '#'-...
步骤二：添加算法语句
重要 当前仅Spark Batch、Spark SQL、Elastic Job和MaxCompue MR、Elastic Service、Blink、Blink DataStream、Flink DataStream、Flink Vvp Stream、Flink Vvp Stream、Flink Vvp SQL、Flink Vvr Stream、Flink Vvr SQL、Flink SQL和Spark...
步骤二：添加算法语句
重要 当前仅Spark Batch、Spark SQL、Elastic Job和MaxCompue MR、Elastic Service、Blink、Blink DataStream、Flink DataStream、Flink Vvp Stream、Flink Vvp Stream、Flink Vvp SQL、Flink Vvr Stream、Flink Vvr SQL、Flink SQL和Spark...
BITNOT
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITNOT函数。语法 INT BITNOT(INT number)说明 输入和输出类型均为整型，且类型一致。入参 参数 数据类型 number INT 示例 测试数据 a(INT)7 测试语句 SELECT BITNOT(a)as var1 FROM T1;...
什么是阿里云实时计算Flink版
产品架构 产品优势 阿里云实时计算Flink版作为企业级高性能Serverless实时大数据处理系统，集成Apache Flink内核，100%兼容Apache Flink，并提供丰富的企业级增值功能。在成本上，基于Serverless的服务支持作业弹性扩缩容，只需增加计算...
自定义表值函数（UDTF）
Flink SQL作业开发。详情请参见 作业开发。ASI_UDTF_Source表中message字段每行字符串按照竖线（|）分割成多列，代码示例如下。CREATE TEMPORARY TABLE ASI_UDTF_Source(`message` VARCHAR)WITH('connector'='datagen');CREATE TEMPORARY ...
BITAND
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITAND函数。语法 INT BITAND(INT number1,INT number2)说明 输入和输出类型均为整型，且类型一致。入参 参数 数据类型 number1 INT number2 INT 示例 测试数据 a(INT)b(INT)2 3 测试语句 ...
BITOR
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITOR函数。语法 INT BITOR(INT number1,INT number2)入参 参数 数据类型 number1 INT number2 INT 说明 输入和输出类型均为整型，且类型一致。示例 测试数据 a(INT)b(INT)2 3 测试语句 ...
获取自动SQL优化事件的统计数据
调用GetInstanceSqlOptimizeStatistic接口，获取指定时间段内自动SQL优化任务的统计数据，包括任务总数和最大收益等。接口说明 使用该接口需满足以下前提条件：使用阿里云或 DAS 的 SDK 时，建议使用最新版本。使用 SDK 调用 DAS 服务时，...
BITXOR
使用限制 仅实时计算引擎VVR 3.0.0及以上版本支持BITXOR函数。语法 INT BITXOR(INT number1,INT number2)入参 参数 数据类型 number1 INT number2 INT 说明 输入和输出类型均为整型，且类型一致。示例 测试数据 a(INT)b(INT)2 3 测试语句 ...
Maxwell
Flink支持将Maxwell JSON消息解析为INSERT、UPDATE或DELETE消息到Flink SQL系统中。在很多情况下，利用这个特性非常的有用，例如：将增量数据从数据库同步到其他系统 日志审计 数据库的实时物化视图 数据库表的temporal join变更历史 Flink...
- 产品推荐
- 这些文档可能帮助您