华为云用户手册

通过包年/包月方式重购的WAF与原WAF在同一区域 原WAF上的配置数据可以保存24小时。 退订WAF后，WAF将暂停防护 域名 。当您重新购买WAF后，您只需要为域名开启防护，即将域名的“工作模式”切换为“开启防护”。开启防护后，WAF会根据域名在原WAF上配置的防护对域名进行防护。 有关退订WAF的详细操作，请参见如何退订 Web应用防火墙 ？。 有关购买WAF的详细操作，请参见购买Web应用防火墙。 有关开启WAF防护的详细操作，请参见切换工作模式。 退订WAF后请您在24小时内重新购买WAF，以免原WAF上的配置数据失效。

Web应用防火墙如何收费？ Web应用防火墙云模式支持包年/包月（预付费）计费方式，独享模式支持按需计费方式。其中，云模式支持入门版、标准版、专业版和铂金版四个版本。同时，云模式包年/包月还支持域名扩展包、带宽扩展包和规则扩展包。您可以根据业务需求选择相应的服务版本和搭配扩展包，服务将根据您选择的计费方式和计费项目进行收费。 有关WAF详细的计费说明，请参见计费说明。 详细的服务资费费率标准请参见产品价格详情。 父主题： 计费、到期续费与退订重购

示例 将流weather_out的数据输出到 表格存储服务 CloudTable的OpenTSDB中。 1 2 3 4 5 6 7 8 910111213141516 CREATE SINK STREAM weather_out ( timestamp_value LONG, /* 时间 */ temperature FLOAT, /* 温度值 */ humidity FLOAT, /* 湿度值 */ location STRING /* 地点 */) WITH ( type = "opentsdb", region = "xxx", cluster_id = "e05649d6-00e2-44b4-b0ff-7194adaeab3f", tsdb_metrics = "weather", tsdb_timestamps = "${timestamp_value}", tsdb_values = "${temperature}; ${humidity}", tsdb_tags = "location:${location},signify:temperature; location:${location},signify:humidity", batch_insert_data_num = "10");

DMS输入流 分布式消息服务（Distributed Message Service，简称DMS）是一项基于高可用分布式集群技术的消息中间件服务，提供了可靠且可扩展的托管消息队列，用于收发消息和存储消息。分布式消息服务Kafka是一款基于开源社区版Kafka提供的消息队列服务，向用户提供可靠的全托管式的Kafka消息队列。 DLI 支持创建输入流从DMS的Kafka获取数据，作为作业的输入数据。创建DMS Kafka输入流的语法与创建开源Apache Kafka输入流一样，具体请参见开源Kafka输入流。 父主题： 创建输入流

DMS输出流 分布式消息服务（Distributed Message Service，简称DMS）是一项基于高可用分布式集群技术的消息中间件服务，提供了可靠且可扩展的托管消息队列，用于收发消息和存储消息。分布式消息服务Kafka是一款基于开源社区版Kafka提供的消息队列服务，向用户提供可靠的全托管式的Kafka消息队列。 DLI支持将作业的输出数据输出到DMS的Kafka实例中。创建DMS Kafka输出流的语法与创建开源Apache Kafka输出流一样，具体请参见 MRS Kafka输出流。 父主题： 创建输出流

Flink SQL语法概览 本章节介绍了目前DLI所提供的Flink SQL语法列表。参数说明，示例等详细信息请参考具体的语法说明。 表1 流作业语法概览 语法分类 功能描述 创建输入流 CloudTable HBase输入流 创建输入流 DIS输入流 DMS输入流 创建输入流 MRS Kafka输入流 开源Kafka输入流 OBS输入流 创建输出流 CloudTable HBase输出流 创建输出流 CloudTable OpenTSDB输出流 创建输出流 CSS Elasticsearch输出流 D CS 输出流 DDS输出流 DIS输出流 DMS输出流 DWS输出流（通过JDBC方式） DWS输出流（通过OBS转储方式） 创建输出流 MRS HBase输出流 MRS Kafka输出流 开源Kafka输出流 OBS输出流 RDS输出流 创建输出流 SMN 输出流 文件系统输出流(推荐） 创建中间流 创建中间流 创建维表 创建Redis表 创建RDS表 自拓展生态 自拓展输入流 自拓展输出流 父主题： Flink SQL语法参考（不再演进，推荐使用Flink OpenSource SQL）

语法说明 COMPUTED COLUMN 计算列是一个使用 “column_name AS computed_column_expression” 语法生成的虚拟列。它由使用同一表中其他列的非查询表达式生成，并且不会在表中进行物理存储。例如，一个计算列可以使用 cost AS price * quantity 进行定义，这个表达式可以包含物理列、常量、函数或变量的任意组合，但这个表达式不能存在任何子查询。 在 Flink 中计算列一般用于为 CREATE TABLE 语句定义 时间属性。 处理时间属性 可以简单地通过使用了系统函数 PROCTIME() 的 proc AS PROCTIME() 语句进行定义。 另一方面，由于事件时间列可能需要从现有的字段中获得，因此计算列可用于获得事件时间列。例如，原始字段的类型不是 TIMESTAMP(3) 或嵌套在 JSON 字符串中。 注意： 定义在一个数据源表（ source table ）上的计算列会在从数据源读取数据后被计算，它们可以在 SELECT 查询语句中使用。 计算列不可以作为 INSERT 语句的目标，在 INSERT 语句中，SELECT 语句的 schema 需要与目标表不带有计算列的 schema 一致。

创建源表相关语法 表1 创建源表相关语法 语法分类 功能描述 创建源表 Kafka源表 DIS源表 JDBC源表 DWS源表 Redis源表 Hbase源表 userDefined源表 创建结果表 ClickHouse结果表 Kafka结果表 Upsert Kafka结果表 DIS结果表 JDBC结果表 DWS结果表 Redis结果表 SMN结果表 Hbase结果表 Elasticsearch结果表 userDefined结果表 创建维表 创建JDBC维表 创建DWS维表 创建Hbase维表

算术运算符 算术运算符包括双目运算符与单目运算符，这些运算符都将返回数字类型。Flink SQL所支持的算术运算符如表3所示。 表3 算术运算符 运算符 返回类型 描述 + numeric 所有数字类型 返回数字。 - numeric 所有数字类型 返回负数。 A + B 所有数字类型 A和B相加。结果数据类型与操作数据类型相关，例如一个整数类型数据加上一个浮点类型数据，结果数值为浮点类型数据。 A - B 所有数字类型 A和B相减。结果数据类型与操作数据类型相关。 A * B 所有数字类型 A和B相乘。结果数据类型与操作数据类型相关。 A / B 所有数字类型 A和B相除。结果是一个double（双精度）类型的数值。 POWER(A, B) 所有数字类型 返回A数的B次方乘幂。 ABS(numeric) 所有数字类型 返回数值的绝对值。 MOD(A, B) 所有数字类型 返回A除以B的余数（模数）。 返回值只有在A为负数时才为负数。 SQRT(A) 所有数字类型 返回A的平方根。 LN(A) 所有数字类型 返回A的自然对数（基数e）。 LOG 10(A) 所有数字类型 返回A的基数10对数。 EXP(A) 所有数字类型 返回e的a次方。 CEIL(A) CEILING(A) 所有数字类型 将参数向上舍入为最接近的整数。例如ceil(21.2)，返回22。 FLOOR(A) 所有数字类型 对给定数据进行向下舍入最接近的整数。例如floor(21.2)，返回21。 SIN(A) 所有数字类型 计算给定A的正弦值。 COS(A) 所有数字类型 计算给定A的余弦值。 TAN(A) 所有数字类型 计算给定A的正切值。 COT(A) 所有数字类型 计算给定A的余切值。 ASIN(A) 所有数字类型 计算给定A的反正弦值。 ACOS(A) 所有数字类型 计算给定A的反余弦值。 ATAN(A) 所有数字类型 计算给定A的反正切值。 DEGREES(A) 所有数字类型 返回弧度所对应的角度。 RADIANS(A) 所有数字类型 返回角度所对应的弧度。 SIGN(A) 所有数字类型 返回a所对应的正负号，a为正返回1，a为负，返回-1，否则返回0。 ROUND(A, d) 所有数字类型 返回小数部分d位之后数字的四舍五入，d为int型。例如round(21.263,2)，返回21.26。 PI() 所有数字类型 返回pi的值。 字符串类型不能参与算术运算。

U UESCAPE UNBOUNDED UNCOMMITTED UNDER UNION UNIQUE UNKNOWN UNNAMED UNNEST UPDATE UPPER UPSERT URN_COLUMN USAGE USER USER_DEFINED_TYPE_CATALOG USER_DEFINED_TYPE_CODE USER_DEFINED_TYPE_NAME USER_DEFINED_TYPE_SCHEMA USERNAME USING

T TABLE TABLESAMPLE TABLE_COLUMNS TABLE_NAME TABLE_NAME_MAP TEMP TEMPORARY THEN TIES TIME TIMESTAMP TIMESTAMPADD TIMESTAMPDIFF TIMEZONE_HOUR TIMEZONE_MINUTE TINYINT TO TOP_LEVEL_COUNT TOPIC TOPIC_URN TRAILING TRANSACTION TRANSACTIONAL_TABLE TRANSACTIONS_ACTIVE TRANSACTIONS_COMMITTED TRANSACTIONS_ROLLED_BACK TRANSFORM TRANSFO RMS TRANSLATE TRANSLATION TRANX_ID TREAT TRIGGER TRIGGER_CATALOG TRIGGER_NAME TRIGGER_SCHEMA TRIM TRUE TSDB_LINK_ADDRESS TSDB_METRICS TSDB_TIMESTAMPS TSDB_TAGS TSDB_VALUES TYPE TYPE_CLASS_NAME TYPE_CLASS_PA RAM ETER

M M MAP MATCH MATCHED MATCHING_COLUMNS MATCHING_REGEX MAX MAXALLOWEDCPU MAXALLOWEDMEM MAXALLOWEDPARALLELISM MAX_DUMP_FILE_NUM MAX_RECORD_NUM_CACHE MAX_RECORD_NUM_PER_FILE MAXVALUE MEMBER MERGE MESSAGE_COLUMN MESSAGE_LENGTH MESSAGE_OCTET_LENGTH MESSAGE_SUBJECT MESSAGE_TEXT METHOD MICROSECOND MILLENNIUM MIN MINUTE MINVALUE MOD MODIFIES MODULE MONTH MORE MS MULTISET MUMPS

E EACH ELEMENT ELSE EMAIL_KEY ENABLECHECKPOINT ENABLE_CHECKPOINT ENABLE_OUTPUT_NULL ENCODE ENCODE_CLASS_NAME ENCODE_CLASS_PARAMETER ENCODED_DATA END ENDPOINT END_EXEC EPOCH EQUALS ESCAPE ES_FIELDS ES_INDEX ES_TYPE ESTIMATEMEM ESTIMATEPARALLELISM EXACTLY_ONCE EXCEPT EXCEPTION EXCLUDE EXCLUDING EXEC EXECUTE EXISTS EXP EXPLAIN EXTEND EXTERNAL EXTRACT EVERY

P PAD PARALLELISM PARAMETER PARAMETER_MODE PARAMETER_NAME PARAMETER_ORDINAL_POSITION PARAMETER_SPECIFIC_CATALOG PARAMETER_SPECIFIC_NAME PARAMETER_SPECIFIC_SCHEMA PARTIAL PARTITION PARTITION_COUNT PARTITION_KEY PARTITION_RANGE PASCAL PASSTHROUGH PASSWORD PATH PERCENTILE_CONT PERCENTILE_DISC PERCENT_RANK PERSIST_SCHEMA PIPELINE_ID PLACING PLAN PLI POSITION POWER PRECEDING PRECISION PREPARE PRESERVE PRIMARY PRIMARY_KEY PRIOR PRIVILEGES PROCEDURE PROCTIME PROJECT_ID PUBLIC

D DATE DATABASE DATE DATETIME_INTERVAL_CODE DATETIME_INTERVAL_PRECISION DAY DB_COLUMNS DB_URL DB_OBS_SERVER DB_TYPE DEALLOCATE DEC DECADE DECIMAL DECLARE DEFAULTS DEFERRABLE DEFERRED DEFINER DEGREE DELETE DELETE_OBS_TEMP_FILE DENSE_RANK DEPTH DEREF DERIVED DESC DESCRIBE DESCRIPTION DESCRIPTOR DETERMINISTIC DIAGNOS TICS DISALLOW DISCONNECT DIS_NOTICE_CHANNEL DISPATCH DISTINCT DOMAIN DOUBLE DOW DOY DRIVER DROP DUMP_INTERVAL DYNAMIC DYNAMIC_FUNCTION DYNAMIC_FUNCTION_CODE

I IDENTITY ILLEGAL_DATA_TABLE IMMEDIATE IMPLEMENTATION IMPORT IN INCLUDING INCREMENT INDICATOR INITIALLY INNER INOUT INPUT INSENSITIVE INSERT INSTANCE INSTANTIABLE INT INTEGER INTERSECT INTERSECTION INTERVAL INTO INVOKER IN_WITH_SCHEMA IS ISOLATION

R RANGE RANK RAW READ READS READ_ONCE REAL RECURSIVE REF REFEREN CES REFERENCING REGION REGR_AVGX REGR_AVGY REGR_COUNT REGR_INTERCEPT REGR_R2 REGR_SLOPE REGR_SXX REGR_SXY REGR_SYY RELATIVE RELEASE REPEATABLE RESET RESTART RESTRICT RESULT RETURN RETURNED_CARDINALITY RETURNED_LENGTH RETURNED_OCTET_LENGTH RETURNED_SQLSTATE RETURNS REVOKE RIGHT ROLE ROLLBACK ROLLING_INTERVAL ROLLING_SIZE ROLLUP ROUTINE ROUTINE_CATALOG ROUTINE_NAME ROUTINE_SCHEMA ROW ROW_COUNT ROW_DELIMITER ROW_NUMBER ROWS ROWTIME

S SAVEPOINT SCALE SCHEMA SCHEMA_CASE_SENSITIVE SCHEMA_NAME SCOPE SCOPE_CATALOGS SCOPE_NAME SCOPE_SCHEMA SCROLL SEARCH SECOND SECTION SECURITY SELECT SELF SENSITIVE SEQUENCE SERIALIZABLE SERVER SERVER_NAME SESSION SESSION_USER SET SETS SIMILAR SIMPLE SINK SIZE SK SMALLINT SOME SOURCE SPACE SPECIFIC SPECIFICTYPE SPECIFIC_NAME SQL SQLEXCEPTION SQLSTATE SQLWARNING SQL_TSI_DAY SQL_TSI_FRAC_SECOND SQL_TSI_HOUR SQL_TSI_MICROSECOND SQL_TSI_MINUTE SQL_TSI_MONTH SQL_TSI_QUARTER SQL_TSI_SECOND SQL_TSI_WEEK SQL_TSI_YEAR SQRT START START_TIME STATE STATEMENT STATIC STDDEV_POP STDDEV_SAMP STREAM STRING STRUCTURE STYLE SUBCLASS_ORIGIN SUBMULTISET SUBSTITUTE SUBSTRING SUM SYMMETRIC SYSTEM SYSTEM_USER

A A ABS ABSOLUTE ACTION ADA ADD ADMIN AFTER AK ALL ALLOCATE ALLOW ALTER ALWAYS AND ANY APPEND APP_ID ARE ARRAY ARRAY_BRACKET AS ASC ASENSITIVE ASSERTION ASSIGNMENT ASYMMETRIC AT AT_LEAST_ONCE ATOMIC ATTRIBUTE ATTRIBUTES AUTHORIZATION AVG AVRO_CONFIG AVRO_DATA AVRO_SCHEMA

C C CACHE_MAX_NUM CACHE_TIME CALL CALLED CARDINALITY CASCADE CASCADED CASE CAST CATALOG CATALOG_NAME CEIL CEILING CENTURY CHAIN CHANNEL CHAR CHARACTER CHARACTERISTI CTS CHARACTERS CHARACTER_LENGTH CHARACTER_SET_CATALOG CHARACTER_SET_NAME CHARACTER_SET_SCHEMA CHAR_LENGTH CHECK CHECKPOINT_APP_NAME CHECKPOINT_INTERVAL CHECKPOINTINTERVAL CLASS_ORIGIN CLOB CLOSE CLUSTER_ADDRESS CLUSTER_ID CLUSTER_NAME COALESCE COBOL COLLATE COLLATION COLLATION_CATALOG COLLATION_NAME COLLATION_SCHEMA COLLECT COLUMN COLUMN_NAME COLUMN_NAME_MAP COMMAND_FUNCTION COMMAND_FUNCTION_CODE COMMIT COMMITTED CONDITION CONDITION_NUMBER CONFIGURATION CONFLUENT_CERTIFICATE_NAME CONFLUENT_PROPERTIES CONFLUENT_SCHEMA_FIELD CONFLUENT_URL CONNECT CONNECTION_NAME CONSTRAINT CONSTRAINTS CONSTRAINT_CATALOG CONSTRAINT_NAME CONSTRAINT_SCHEMA CONSTRUCTOR CONTAINS CONTINUE CONVERT CORR CORRESPONDING COUNT COVAR_POP COVAR_SAMP CREATE CREATE_IF_NOT_EXIST CROSS CUBE CUME_DIST CURRENT CURRENT_CATALOG CURRENT_DATE CURRENT_DEFAULT_TRANSFORM_GROUP CURRENT_PATH CURRENT_ROLE CURRENT_SCHEMA CURRENT_TIMESTAMP CURRENT_TRANSFORM_GROUP_FOR_TYPE CURRENT_USER CURSOR CURSOR_NAME CYCLE

示例 输入一条记录("student1", "student2, student3")，输出两条记录("student1", "student2") 和 ("student1", "student3") 。 create source stream s1(attr1 string, attr2 string) with (......);insert into s2 select attr1, b1 from s1 left join lateral table(split_cursor(attr2, ',')) as T(b1) on true;

RPAD 功能描述 将pad字符串拼接到str字符串的的右端，直到新的字符串达到指定长度len为止。 如果任意参数为null时，则返回null。 len为负数时，返回为null。 pad为空串，如果len小于str长度，返回str裁剪为len长度的字符串。 语法 VARCHAR RPAD(VARCHAR str, INT len, VARCHAR pad) 参数说明 str：启始的字符串。 len：新的字符串的长度。 pad：需要重复补充的字符串。 示例 测试语句 SELECT RPAD("adc", 2, "hello"), RPAD("adc", -1, "hello"), RPAD("adc", 10, "hello"); 测试结果 "ad",,"adchellohe"

STRING_TO_ARRAY 功能描述 将字符串value按delimiter分隔为字符串数组。 delimiter使用的是java的正则表达式，若使用特殊字符则需要转义。 语法 ARRAY[String] STRING_TO_ARRAY(STRING value, VARCHAR delimiter) 参数说明 value：字符串。 delimiter：分隔符。 示例 测试语句 SELECT string_to_array("127.0.0.1", "\\."), string_to_array("red-black-white-blue", "-"); 测试结果 [127,0,0,1],[red,black,white,blue]

TRIM 功能描述 从B中除去字符串首尾/首位/末尾的A。默认情况下，首尾的A都被删除。 语法 STRING TRIM( { BOTH | LEADING | TRAILING } STRING a FROM STRING b) 参数说明 a：字符串。 b：字符串。 示例 测试语句 SELECT TRIM(BOTH " " FROM " hello world "); 测试结果 "hello world"

SUBSTRING 功能描述 返回从指定位置开始的A的子字符串。起始位置从1开始。 如果未指定len，则截取从位置start开始，到字符串结尾的子字符串。 如果指定len，则截取从位置start开始，长度为len的子字符串。 start从1开始，start为0时当1看待，为负数时表示从字符串末尾倒序计算位置。 语法 VARCHAR SUBSTRING(STRING A FROM INT start) 或 VARCHAR SUBSTRING(STRING A FROM INT start FOR INT len) 参数说明 A：指定的字符串。 start：在字符串A中开始截取的位置。 len：截取的长度。 示例 测试语句1 SELECT SUBSTRING("123456" FROM 2); 测试结果1 "23456" 测试语句2 SELECT SUBSTRING("123456" FROM 2 FOR 4); 测试结果2 "2345"

IS_ALPHA 功能描述 判断字符串是否只包含字母。 语法 BOOLEAN IS_ALPHA(VARCHAR content) 参数说明 content：输入字符串。 示例 测试语句 SELECT IS_ALPHA(content) AS case_result FROM T1; 测试数据和结果 表5 测试数据和结果 测试数据（content） 测试结果（case_result） Abc true abc1#$ false null false ""(空字符串) false

IS_NUMBER 功能描述 判断字符串是否是数值。 语法 BOOLEAN IS_NUMBER(VARCHAR content) 参数说明 content：输入字符串。 示例 测试语句 SELECT IS_NUMBER(content) AS case_result FROM T1; 测试数据和结果 表7 测试数据和结果 测试数据（content） 测试结果（case_result） 78 true 78.0 true 78a false null false "" (空字符串) false

JSON_VALUE 功能描述 获取json字符串中指定path的值。 语法 VARCHAR JSON_VALUE(VARCHAR content, VARCHAR path) 参数说明 content：输入字符串。 path：要获取的path路径。 示例 测试语句 SELECT JSON_VALUE(content, path) AS case_result FROM T1; 测试数据和结果 表9 测试数据和结果 测试数据（content，path） 测试结果（case_result） { "a1":"v1","a2":7,"a3":8.0,"a4": {"a41":"v41","a42": ["v1","v2"]}} $ { "a1":"v1","a2":7,"a3":8.0,"a4": {"a41":"v41","a42": ["v1","v2"]}} { "a1":"v1","a2":7,"a3":8.0,"a4": {"a41":"v41","a42": ["v1","v2"]}} $.a1 v1 { "a1":"v1","a2":7,"a3":8.0,"a4": {"a41":"v41","a42": ["v1","v2"]}} $.a4 {"a41":"v41","a42": ["v1","v2"]} { "a1":"v1","a2":7,"a3":8.0,"a4": {"a41":"v41","a42": ["v1","v2"]}} $.a4.a42 ["v1","v2"] { "a1":"v1","a2":7,"a3":8.0,"a4": {"a41":"v41","a42": ["v1","v2"]}} $.a4.a42[0] v1

REPLACE 功能描述 字符串替换函数，将字符串str1中的所有str2替换成str3。 语法 VARCHAR REPLACE(VARCHAR str1, VARCHAR str2, VARCHAR str3) 参数说明 str1：原字符。 str2：目标字符。 str3：替换字符。 示例 测试语句： SELECT replace( "hello world hello world hello world", "world", "hello" ); 测试结果 "hello hello hello hello hello hello"

CONCAT_WS 功能描述 将每个参数值和第一个参数separator指定的分隔符依次连接到一起组成新的字符串，长度和类型取决于输入值。 如果separator取值为null，则将separator视作与空串进行拼接。如果其它参数为null，在执行拼接过程中跳过取值为null的参数。 语法 VARCHAR CONCAT_WS(VARCHAR separator, VARCHAR var1, VARCHAR var2, ...) 参数说明 separator：分隔符。 var1：字符串。 var2：字符串。 示例 测试语句 SELECT CONCAT_WS("-", "abc", "def", "ghi", "jkl"); 测试结果 "abc-def-ghi-jkl"