实时计算怎么使用-实时计算怎么使用文档介绍内容-阿里云

云消息队列 RocketMQ 版

重要鉴于云消息队列 RocketMQ 版 4.x标准版当前最高可达每秒5千条消息的限速机制，使用该版作为实时计算Flink版对接的消息中间件，可能会导致Flink作业运行不稳定。因此，在选择消息中间件时，如果您正在或计划通过标准版RocketMQ与Flink...

REGEXP

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持REGEXP函数。语法 BOOLEAN REGEXP(VARCHAR str,VARCHAR pattern)入参参数数据类型说明 str VARCHAR 指定的字符串。pattern VARCHAR 指定的匹配模式。说明如果str或pattern为NULL，则...

环境准备

使用实时计算Flink服务首次使用实时计算Flink时，请根据如下步骤开通实时计算Flink服务以及创建Flink全托管实例。开通实时计算Flink服务。具体操作，请参见开通Flink全托管。创建Flink全托管实例。具体操作，请参见创建与管理项目空间。...

CONV

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持CONV函数。CONV函数精度为64位。语法 VARCHAR CONV(BIGINT number,INT FROM_BASE,INT TO_BASE)or VARCHAR CONV(VARCHAR number,INT FROM_BASE,INT TO_BASE)入参参数数据类型说明 number ...

日志服务SLS

说明 实时计算Flink版默认不具备访问公网的能力，但阿里云提供的NAT网关可以实现VPC网络与公网网络互通，详情请参见 Flink全托管如何访问公网？project SLS项目名称。String 是无无。logStore SLS LogStore或metricstore名称。String 是 ...

实时计算Blink产品公告（已停止新购）

如果您有新购需求，推荐使用实时计算Flink全托管。RocketMQ接入点变更导致实时计算作业适配升级公告升级公告因消息队列RocketMQ接入点地域化变更（详情请参见关于TCP内网接入点设置的公告），如果您已使用了Blink 3.7.10以下版本的...

BITNOT

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持BITNOT函数。语法 INT BITNOT(INT number)说明输入和输出类型均为整型，且类型一致。入参参数数据类型 number INT 示例测试数据 a(INT)7 测试语句 SELECT BITNOT(a)as var1 FROM T1;...

实时计算Flink版产品公告

【计费变更】实时计算Flink版监控服务ARMS Prometheus上线新版计费模式自2023年12月8日起，实时计算Flink版对接ARMS Prometheus新版计费模式，可观测监控Prometheus版专家版的计费模式变更为按写入的可观测数据量收费，相比旧版计费预估可...

资源抵扣包

免费试用：实时计算Flink版新用户可以在免费试用页面，单击实时计算Flink版卡片上的立即试用，根据页面提示领取5000 CUH资源抵扣包，开通Flink进行试用。试用完毕后请及时释放不需要的资源，避免产生额外费用。59元优惠：在产品规格 ...

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持DATEDIFF函数。语法 INT DATEDIFF(VARCHAR enddate,VARCHAR startdate)INT DATEDIFF(TIMESTAMP enddate,VARCHAR startdate)INT DATEDIFF(VARCHAR enddate,TIMESTAMP startdate)INT DATEDIFF...

实时数据集成（Flink版）

本文介绍使用实时计算Flink版的连接器功能集成物联网平台实例下数据服务中数据的完成流程。前提条件已完成实时计算Flink版服务开通和准备工作。如果您使用RAM用户或RAM角色等身份访问，需要确认已具有Flink控制台相关权限，详情请参见 ...

BITXOR

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持BITXOR函数。语法 INT BITXOR(INT number1,INT number2)入参参数数据类型 number1 INT number2 INT 说明输入和输出类型均为整型，且类型一致。示例测试数据 a(INT)b(INT)2 3 测试语句 ...

SPLIT_INDEX

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持SPLIT_INDEX函数。语法 VARCHAR SPLIT_INDEX(VARCHAR str,VARCHAR sep,INT index)入参参数数据类型说明 str VARCHAR 目标字符串。sep VARCHAR 分隔符。index INT 字段位置，index从0开始...

TO_DATE

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持TO_DATE函数。语法 Date TO_DATE(INT time)Date TO_DATE(VARCHAR date)Date TO_DATE(VARCHAR date,VARCHAR format)入参参数数据类型说明 time INT 表示从1970-1-1到所表示时间之间天数。...

DATE_SUB

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持DATE_SUB函数。语法 DATE DATE_SUB(VARCHAR startdate,INT days)DATE DATE_SUB(TIMESTAMP time,INT days)入参参数数据类型 startdate VARCHAR 说明 VARCHAR类型日期格式为 yyyy-MM-dd 或 ...

UNIX_TIMESTAMP

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持UNIX_TIMESTAMP函数。语法 BIGINT UNIX_TIMESTAMP(VARCHAR date)BIGINT UNIX_TIMESTAMP(TIMESTAMP timestamp)BIGINT UNIX_TIMESTAMP(VARCHAR date,VARCHAR format)入参参数数据类型说明 ...

DATE_ADD

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持DATE_ADD函数。语法 DATE DATE_ADD(VARCHAR startdate,INT days)DATE DATE_ADD(TIMESTAMP time,INT days)入参参数数据类型 startdate TIMESTAMP、VARCHAR 说明 VARCHAR类型日期格式为 ...

开通实时计算Flink版

使用实时计算Flink版需要开通工作空间，每个工作空间的计算资源隔离，开发控制台相互独立。本文为您介绍开通Flink工作空间的操作步骤，以及开通过程中的注意事项。前提条件已拥有阿里云账号。如果您还没有阿里云账号，请先完成注册，详情...

STRING_SPLIT

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持STRING_SPLIT函数。语法 string_split(string,separator)入参参数数据类型说明 string VARCHAR 目标字符串。separator VARCHAR 指定的分隔符。说明 separator暂不支持多字符串形式，只...

BITOR

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持BITOR函数。语法 INT BITOR(INT number1,INT number2)入参参数数据类型 number1 INT number2 INT 说明输入和输出类型均为整型，且类型一致。示例测试数据 a(INT)b(INT)2 3 测试语句 ...

BITAND

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持BITAND函数。语法 INT BITAND(INT number1,INT number2)说明输入和输出类型均为整型，且类型一致。入参参数数据类型 number1 INT number2 INT 示例测试数据 a(INT)b(INT)2 3 测试语句 ...

LAST_VALUE

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持LAST_VALUE函数。语法 T LAST_VALUE(T value)T LAST_VALUE(T value，BIGINT order)入参参数数据类型说明 value 任意参数类型指定数据流。order BIGINT 根据order判定LAST_VALUE所在的行...

FIRST_VALUE

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持FIRST_VALUE函数。语法 FIRST_VALUE(T value)FIRST_VALUE(T value,BIGINT order)入参参数数据类型说明 value 任意参数类型指定数据流。说明如果输入数据全为NULL，则返回NULL。order ...

KEYVALUE

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持KEYVALUE函数。语法 VARCHAR KEYVALUE(VARCHAR str,VARCHAR split1,VARCHAR split2,VARCHAR key_name)入参参数数据类型说明 str VARCHAR 待拆分的目标字符串。split1 VARCHAR 按照split1...

FROM_UNIXTIME

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持FROM_UNIXTIME。语法 VARCHAR FROM_UNIXTIME(BIGINT unixtime,VARCHAR format)入参参数数据类型说明 unixtime BIGINT 以秒为单位的时间戳。format VARCHAR 可选，日志格式，默认格式为 ...

REGEXP_REPLACE

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持REGEXP_REPLACE函数。语法 VARCHAR REGEXP_REPLACE(VARCHAR str,VARCHAR pattern,VARCHAR replacement)入参参数数据类型说明 str VARCHAR 指定的字符串。pattern VARCHAR 被替换的字符串...

GENERATE_SERIES

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持GENERATE_SERIES函数。语法 GENERATE_SERIES(BIGINT from,BIGINT to)入参参数数据类型 from BIGINT类型，指定下界，包含下界值。to BIGINT类型，指定上界，不包含上界值。示例测试数据 ...

步骤一：准备工作

同步RAM用户账号至Dataphin 步骤三：实时计算Flink版、Quick BI开通与配置主流程描述操作指导开通实时计算Flink版 购买实时计算Flink版。开通实时计算Flink版 开通Quick BI（非必选）购买Quick BI。重要非必选，也可以使用其他BI工具...

步骤一：准备工作

同步RAM用户账号至Dataphin 步骤三：实时计算Flink版、Quick BI开通与配置主流程描述操作指导开通实时计算Flink版 购买实时计算Flink版。开通实时计算Flink版 开通Quick BI（非必选）购买Quick BI。重要非必选，也可以使用其他BI工具...

迁移操作

本文为您介绍如何将Bayes上的作业迁移到 实时计算开发控制台，包括迁移步骤、使用限制和注意事项。前提条件您已具备Bayes对应项目的Owner权限和目标Flink项目空间的Owner权限，Flink权限管理详情，请参见权限管理。Flink工作空间和Bayes...

查看与修改作业运行状态

前提条件其他阿里云账号或RAM用户共同使用实时计算Flink版产品时，需要为阿里云账号或RAM用户授权，以进行查看与修改作业运行状态等相关操作，详情请参见作业操作账号授权。查看作业运行状态登录实时计算控制台。在 Flink全托管页签，...

云原生数据仓库AnalyticDB PostgreSQL版（ADB PG）

使用限制仅Flink实时计算引擎VVR 6.0.0及以上版本支持云原生数据仓库AnalyticDB PostgreSQL版连接器。仅Flink实时计算引擎VVR 8.0.1及以上版本支持云原生数据仓库AnalyticDB PostgreSQL版7.0版本。暂不支持自建的Postgres SQL。语法结构 ...

JSON_TUPLE

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持JSON_TUPLE函数。语法 JSON_TUPLE(str,path1,path2.,pathN)入参参数数据类型说明 str VARCHAR JSON字符串。path1～pathN VARCHAR 表示路径的字符串，前面不需要$。示例测试数据表 1.T1...

DATE_FORMAT_TZ

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持DATE_FORMAT_TZ函数。语法 VARCHAR DATE_FORMAT_TZ(TIMESTAMP timestamp,VARCHAR format,VARCHAR timezone)VARCHAR DATE_FORMAT_TZ(TIMESTAMP timestamp,VARCHAR timezone)入参参数数据...

复杂事件处理（CEP）语句

在阿里云实时计算Flink版的SQL作业中使用SQL标准中的语法(.)来定义组合模式，支持使用循环量词如+、*、{3,} 等。例如对于模式 PATTERN(A(B C*)+?D)，其中(B C*)为一个组合模式，并指定该组合循环出现一次以上，?表明为非贪婪匹配，其对应...

DATE_FORMAT

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持DATE_FORMAT函数。语法 VARCHAR DATE_FORMAT(TIMESTAMP time,VARCHAR to_format)VARCHAR DATE_FORMAT(VARCHAR date,VARCHAR to_format)VARCHAR DATE_FORMAT(VARCHAR date,VARCHAR from_...

TO_TIMESTAMP_TZ

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持TO_TIMESTAMP_TZ函数。语法 TIMESTAMP TO_TIMESTAMP_TZ(VARCHAR date,VARCHAR timezone)TIMESTAMP TO_TIMESTAMP_TZ(VARCHAR date,VARCHAR format，VARCHAR timezone)入参参数数据类型 ...

PARSE_URL

使用限制仅实时计算引擎VVR 3.0.0及以上版本支持PARSE_URL函数。语法 VARCHAR PARSE_URL(VARCHAR urlStr,VARCHAR partToExtract[,VARCHAR key])入参参数数据类型说明 urlStr VARCHAR 目标URL。说明如果urlStr参数值为NULL时，则返回值...

项目空间授权

角色支持的功能 实时计算Flink版支持添加阿里云账号、RAM用户、RAM角色账号扮演的阿里云主账号为成员，并对添加的成员绑定owner、editor或viewer角色。不同角色可以使用的功能差异如下表所示。功能 owner editor viewer 查看作业列表 Y Y Y...

实时计算Flink版行业案例

相关文档什么是阿里云实时计算Flink版 应用场景开通Flink全托管

实时计算怎么使用

新品推荐