Realtime Compute for Apache Flink:Funciones compatibles

Función

Descripción

value1 = value2

Devuelve TRUE si value1 es igual a value2.

value1 \<\> value2

Devuelve TRUE si value1 no es igual a value2.

value1 \> value2

Devuelve TRUE si value1 es mayor que value2.

value1 \>= value2

Devuelve TRUE si value1 es mayor o igual que value2.

value1 \< value2

Devuelve TRUE si value1 es menor que value2.

value1 \<= value2

Devuelve TRUE si value1 es menor o igual que value2.

value IS NULL

Devuelve TRUE si value es NULL.

value IS NOT NULL

Devuelve TRUE si value no es NULL.

value1 IS DISTINCT FROM value2

Devuelve TRUE si value1 y value2 difieren en tipo de dato o valor. Los valores NULL se consideran iguales.

value1 IS NOT DISTINCT FROM value2

Devuelve TRUE si value1 y value2 tienen el mismo tipo de dato y valor. Los valores NULL se consideran iguales.

[value1 BETWEEN \[ASYMMETRIC

SYMMETRIC\] value2 AND value3](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#comparison-functions)

De forma predeterminada (o con ASYMMETRIC), devuelve TRUE si value1 está entre value2 y value3, ambos incluidos.

[value1 NOT BETWEEN \[ASYMMETRIC

SYMMETRIC\] value2 AND value3](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#comparison-functions)

De forma predeterminada (o con ASYMMETRIC), devuelve TRUE si value1 es menor que value2 o mayor que value3.

[string1 LIKE string2 \[ESCAPE char\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#comparison-functions)

Devuelve TRUE si string1 coincide con el patrón string2.

[string1 NOT LIKE string2 \[ESCAPE char\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#comparison-functions)

Devuelve TRUE si string1 no coincide con el patrón string2.

[string1 SIMILAR TO string2 \[ESCAPE char\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#comparison-functions)

Devuelve TRUE si string1 coincide con la expresión regular SQL string2.

[string1 NOT SIMILAR TO string2 \[ESCAPE char\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#comparison-functions)

Devuelve TRUE si string1 no coincide con la expresión regular SQL string2.

[value1 IN (value2 \[, value3\]\*)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#comparison-functions)

Devuelve TRUE si value1 existe en la lista.

[value1 NOT IN (value2 \[, value3\]\*)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#comparison-functions)

Devuelve TRUE si value1 no existe en la lista.

EXISTS (sub-query)

Devuelve TRUE si la subconsulta devuelve como mínimo una fila.

value IN (sub-query)

Devuelve TRUE si value es igual a alguna fila del conjunto de resultados de la subconsulta.

value NOT IN (sub-query)

Devuelve TRUE si value no está en ninguna de las filas que devuelve la subconsulta.

Función

Descripción

BITAND

Ejecuta una operación AND bit a bit.

BITNOT

Ejecuta una operación NOT bit a bit.

BITOR

Ejecuta una operación OR bit a bit.

BITXOR

Ejecuta una operación XOR bit a bit.

boolean1 OR boolean2

Devuelve TRUE si boolean1 o boolean2 es TRUE.

boolean1 AND boolean2

Devuelve TRUE si tanto boolean1 como boolean2 son TRUE.

NOT boolean

Devuelve TRUE si boolean es FALSE; devuelve FALSE si boolean es TRUE; devuelve UNKNOWN si boolean es UNKNOWN.

boolean IS FALSE

Devuelve TRUE si boolean es FALSE; devuelve FALSE si boolean es TRUE o UNKNOWN.

boolean IS NOT FALSE

Devuelve TRUE si boolean es TRUE o UNKNOWN; devuelve FALSE si boolean es FALSE.

boolean IS TRUE

Devuelve TRUE si boolean es TRUE; devuelve FALSE si boolean es FALSE o UNKNOWN.

boolean IS NOT TRUE

Devuelve TRUE si boolean es FALSE o UNKNOWN; devuelve FALSE si boolean es TRUE.

boolean IS UNKNOWN

Devuelve TRUE si boolean es UNKNOWN; devuelve FALSE si boolean es TRUE o FALSE.

boolean IS NOT UNKNOWN

Devuelve TRUE si boolean es TRUE o FALSE; devuelve FALSE si boolean es UNKNOWN.

Función

Descripción

+ numeric

Devuelve el valor numérico.

- numeric

Devuelve la negación de numeric.

numeric1 + numeric2

Devuelve la suma de numeric1 y numeric2.

numeric1 - numeric2

Devuelve la diferencia entre numeric1 y numeric2.

numeric1 \* numeric2

Devuelve el producto de numeric1 y numeric2.

numeric1 / numeric2

Devuelve el cociente de numeric1 dividido entre numeric2.

numeric1 % numeric2

Devuelve el residuo de numeric1 dividido entre numeric2.

POWER(numeric1, numeric2)

Devuelve numeric1 elevado a la potencia de numeric2.

ABS(numeric)

Devuelve el valor absoluto de numeric.

SQRT(numeric)

Devuelve la raíz cuadrada de numeric.

LN(numeric)

Devuelve el logaritmo natural (base e) de numeric.

LOG10(numeric)

Devuelve el logaritmo en base 10 de numeric.

LOG2(numeric)

Devuelve el logaritmo en base 2 de numeric.

[LOG(numeric2)

LOG(numeric1, numeric2)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#arithmetic-functions)

Con un argumento, devuelve el logaritmo natural de numeric2. Con dos argumentos, devuelve el logaritmo de numeric2 en base numeric1. Requiere que numeric2 > 0 y numeric1 > 1.

EXP(numeric)

Devuelve e elevado a la potencia de numeric.

[CEIL(numeric)

CEILING(numeric)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#arithmetic-functions)

Redondea numeric hacia arriba al entero más cercano.

FLOOR(numeric)

Redondea numeric hacia abajo al entero más cercano.

SIN(numeric)

Devuelve el seno de numeric.

SINH(numeric)

Devuelve el seno hiperbólico de numeric. Devuelve DOUBLE.

COS(numeric)

Devuelve el coseno de numeric.

TAN(numeric)

Devuelve la tangente de numeric.

TANH(numeric)

Devuelve la tangente hiperbólica de numeric. Devuelve DOUBLE.

COT(numeric)

Devuelve la cotangente de numeric.

ASIN(numeric)

Devuelve el arcoseno de numeric.

ACOS(numeric)

Devuelve el arcocoseno de numeric.

ATAN(numeric)

Devuelve el arcotangente de numeric.

ATAN2(numeric1, numeric2)

Devuelve el arcotangente de la coordenada (numeric1, numeric2).

COSH(numeric)

Devuelve el coseno hiperbólico de numeric. Devuelve DOUBLE.

DEGREES(numeric)

Convierte radianes a grados.

RADIANS(numeric)

Convierte grados a radianes.

SIGN(numeric)

Devuelve el signo de numeric.

ROUND(numeric, INT)

Redondea numeric a INT decimales.

PI()

Devuelve un valor cercano a π.

E()

Devuelve un valor cercano a e.

RAND()

Devuelve un valor double pseudoaleatorio en [0.0, 1.0).

RAND(INT)

Devuelve un valor double pseudoaleatorio en [0.0, 1.0) con la semilla INT.

RAND_INTEGER(INT)

Devuelve un entero pseudoaleatorio en [0, INT).

RAND_INTEGER(INT1, INT2)

Devuelve un entero pseudoaleatorio en [0, INT2) con la semilla INT1.

UUID()

Devuelve una cadena UUID pseudoaleatoria (RFC 4122 Tipo 4).

BIN(INT)

Devuelve la representación en cadena binaria de INT.

[HEX(numeric)

HEX(string)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#arithmetic-functions)

Devuelve la representación en cadena hexadecimal de un número o una cadena.

TRUNCATE(numeric1, integer2)

Trunca numeric1 a integer2 decimales.

UNHEX(expr)

Convierte una cadena hexadecimal a BINARY.

[PERCENTILE(expr, percentage\[, frequency\])](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#arithmetic-functions)

Devuelve el valor exacto del percentil de expr en el porcentaje especificado.

Función

Descripción

[string1

string2](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions)

Devuelve la concatenación de string1 y string2.

[CHAR_LENGTH(string)

CHARACTER_LENGTH(string)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions)

Devuelve el número de caracteres de string.

UPPER(string)

Devuelve string en mayúsculas.

LOWER(string)

Devuelve string en minúsculas.

POSITION(string1 IN string2)

Devuelve la posición (con índice inicial 1) de la primera aparición de string1 en string2. Devuelve 0 si no se encuentra.

[TRIM(\[BOTH

LEADING

TRAILING\] string1 FROM string2)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions)

Elimina las apariciones iniciales, finales o ambas de string1 en string2. Por ejemplo, TRIM(TRAILING 'fe' FROM 'abcdef') devuelve 'abcd'.

LTRIM(string)

Elimina los espacios iniciales de string.

RTRIM(string)

Elimina los espacios finales de string.

REPEAT(string, int)

Devuelve string repetida int veces.

REGEXP_REPLACE

Reemplaza las apariciones de un patrón en una cadena y devuelve el resultado.

[OVERLAY(string1 PLACING string2 FROM integer1 \[FOR integer2\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions)

Reemplaza integer2 caracteres de string1, a partir de la posición integer1, con string2. Si no se especifica, integer2 toma como valor predeterminado la longitud de string2.

[SUBSTRING(string FROM integer1 \[FOR integer2\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions)

Devuelve una subcadena de string que comienza en integer1. Si se especifica integer2, limita la longitud a integer2 caracteres.

REPLACE(string1, string2, string3)

Reemplaza todas las apariciones no superpuestas de string2 en string1 por string3.

[REGEXP_EXTRACT(string1, string2\[, integer\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions)

Divide string1 mediante la expresión regular string2 y devuelve la subcadena en la posición integer.

INITCAP(string)

Convierte la primera letra de cada palabra a mayúscula y el resto a minúsculas.

CONCAT(string1, string2, ...)

Concatena varias cadenas. Devuelve NULL si alguna entrada es NULL.

CONCAT_WS(string1, string2, string3, ...)

Concatena string2, string3, etc., con string1 como separador.

LPAD(string1, integer, string2)

Rellena string1 por la izquierda con string2 hasta alcanzar la longitud integer.

RPAD(string1, integer, string2)

Rellena string1 por la derecha con string2 hasta alcanzar la longitud integer.

FROM_BASE64(string)

Decodifica una cadena codificada en Base64.

TO_BASE64(string)

Codifica string en Base64.

ASCII(string)

Devuelve el código ASCII del primer carácter de string.

CHR(integer)

Devuelve el carácter ASCII correspondiente a integer.

DECODE(binary, string)

Decodifica binary con la codificación especificada (US-ASCII, ISO-8859-1, UTF-8, UTF-16BE, UTF-16LE o UTF-16).

ENCODE(string1, string2)

Codifica string1 con la codificación indicada por string2 (US-ASCII, ISO-8859-1, UTF-8, UTF-16BE, UTF-16LE o UTF-16).

INSTR(string1, string2)

Devuelve la posición de la primera aparición de string2 en string1.

LEFT(string, integer)

Devuelve los integer caracteres más a la izquierda de string.

RIGHT(string, integer)

Devuelve los integer caracteres más a la derecha de string.

[LOCATE(string1, string2\[, integer\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions)

Devuelve la posición de la primera aparición de string1 en string2, a partir de integer.

PARSE_URL

Analiza sintácticamente una parte específica de una URL y devuelve el valor.

REGEXP

Busca un patrón de expresión regular en una cadena y devuelve un valor booleano.

REGEXP_SUBSTR(str, regex)

Devuelve la primera subcadena de str que coincide con regex.

REGEXP_INSTR(str, regex)

Devuelve la posición de la primera subcadena de str que coincide con regex.

REGEXP_COUNT(str, regex)

Devuelve el número de veces que str coincide con regex.

[REGEXP_EXTRACT_ALL(str, regex\[, extractIndex\])](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#string-functions)

Extrae todas las subcadenas de str que coinciden con regex y corresponden al grupo extractIndex.

REVERSE(string)

Devuelve string en orden inverso.

SPLIT_INDEX

Divide una cadena mediante un delimitador y devuelve el elemento en la posición especificada.

[STR_TO_MAP(string1\[, string2, string3\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions)

Divide string1 en pares clave-valor mediante delimitadores y devuelve un mapa.

[SUBSTR(string\[, integer1\[, integer2\]\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#string-functions)

Devuelve una subcadena de string que comienza en integer1 y tiene una longitud de integer2.

[PRINTF(format\[, obj\]\*)](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#string-functions)

Devuelve una cadena con formato estilo printf.

TRANSLATE(expr, fromStr, toStr)

Reemplaza cada carácter de fromStr por el carácter correspondiente de toStr.

[ELT(index, expr\[, exprs\]\*)](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#string-functions)

Devuelve la expresión en la posición index (con índice inicial 1).

[BTRIM(str\[, trimStr\])](https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/functions/systemfunctions/#string-functions)

Elimina de str los caracteres iniciales y finales presentes en trimStr. De forma predeterminada, elimina espacios en blanco.

STARTSWITH(expr, startExpr)

Devuelve TRUE si expr comienza con startExpr. También devuelve TRUE si startExpr está vacía.

ENDSWITH(expr, endExpr)

Devuelve TRUE si expr termina con endExpr. También devuelve TRUE si endExpr está vacía.

Función

Descripción

DATE string

Devuelve un valor SQL DATE analizado a partir de una cadena con el formato yyyy-MM-dd.

DATEDIFF

Calcula la diferencia entre dos valores de fecha.

DATE_ADD

Devuelve una fecha que corresponde a un número específico de días después de una fecha dada.

DATE_SUB

Devuelve una fecha que corresponde a un número específico de días antes de una fecha dada.

TIME string

Devuelve un valor SQL TIME analizado a partir de una cadena con el formato HH:mm:ss.

TIMESTAMP string

Devuelve un valor SQL TIMESTAMP analizado a partir de una cadena con el formato yyyy-MM-dd HH:mm:ss[.SSS].

INTERVAL string range

Analiza intervalos en milisegundos a partir del formato dd hh:mm:ss.fff o en meses a partir del formato yyyy-mm.

LOCALTIME

Devuelve la hora local actual como SQL TIME(0).

LOCALTIMESTAMP

Devuelve la marca de tiempo local actual como SQL TIMESTAMP(3).

CURRENT_TIME

Devuelve la hora local actual como SQL TIME. Equivalente a LOCALTIME.

CURRENT_DATE

Devuelve la fecha local actual como SQL DATE.

CURRENT_TIMESTAMP

Devuelve la marca de tiempo local actual como SQL TIMESTAMP.

NOW()

Devuelve la marca de tiempo local actual como SQL TIMESTAMP. Equivalente a CURRENT_TIMESTAMP.

CURRENT_ROW_TIMESTAMP()

Devuelve la marca de tiempo local actual como SQL TIMESTAMP.

EXTRACT(timeintervalunit FROM temporal)

Extrae un valor LONG para la unidad timeintervalunit especificada a partir de temporal.

YEAR(date)

Devuelve el componente de año de un valor SQL DATE.

QUARTER(date)

Devuelve el componente de trimestre de un valor SQL DATE.

MONTH(date)

Devuelve el componente de mes de un valor SQL DATE.

WEEK(date)

Devuelve el número de semana del año correspondiente a un valor SQL DATE.

DAYOFYEAR(date)

Devuelve el número de día del año correspondiente a un valor SQL DATE.

DAYOFMONTH(date)

Devuelve el número de día del mes correspondiente a un valor SQL DATE.

HOUR(timestamp)

Devuelve el componente de hora de un valor SQL TIMESTAMP.

MINUTE(timestamp)

Devuelve el componente de minuto de un valor SQL TIMESTAMP.

SECOND(timestamp)

Devuelve el componente de segundo de un valor SQL TIMESTAMP.

FLOOR(timepoint TO timeintervalunit)

Redondea timepoint hacia abajo a la unidad timeintervalunit más cercana.

CEIL(timepoint TO timeintervalunit)

Redondea timepoint hacia arriba a la unidad timeintervalunit más cercana.

(timepoint1, temporal1) OVERLAPS (timepoint2, temporal2)

Devuelve TRUE si los dos intervalos de tiempo se superponen.

DATE_FORMAT

Formatea un valor de fecha STRING mediante un patrón específico.

DATE_FORMAT_TZ

Formatea un valor TIMESTAMP como STRING en una zona horaria y un formato específicos.

TIMESTAMPADD(timeintervalunit, interval, timepoint)

Suma un intervalo a timepoint y devuelve el nuevo punto en el tiempo.

TIMESTAMPDIFF(timepointunit, timepoint1, timepoint2)

Devuelve el intervalo de tiempo entre timepoint1 y timepoint2.

CONVERT_TZ(string1, string2, string3)

Convierte la cadena de fecha y hora string1 de la zona horaria string2 a la zona horaria string3. Espera el formato yyyy-MM-dd HH:mm:ss.

FROM_UNIXTIME

Devuelve un valor de fecha VARCHAR a partir de una marca de tiempo Unix.

UNIX_TIMESTAMP

Convierte un valor de fecha en una marca de tiempo Unix.

TO_DATE

Convierte un valor de fecha INT o VARCHAR al tipo de datos DATE.

TO_TIMESTAMP_LTZ(numeric, precision)

Convierte una marca de tiempo Unix a TIMESTAMP_LTZ (milisegundos o segundos).

[TO_TIMESTAMP(string1\[, string2\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#temporal-functions)

Convierte string1 en UTC+0 a una marca de tiempo. De forma predeterminada, asigna a string2 el formato yyyy-MM-dd HH:mm:ss.

TO_TIMESTAMP_TZ

Convierte un valor de fecha VARCHAR a un TIMESTAMP en una zona horaria específica.

CURRENT_WATERMARK(rowtime)

Devuelve la marca de agua actual para la columna rowtime.

Función

Descripción

[CASE value WHEN value1\_1 \[, value1\_2\]\* THEN result1 (WHEN value2\_1 \[, value2\_2\]\* THEN result2)\* (ELSE result\_z) END](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#conditional-functions)

Devuelve resultX si value coincide con algún valor de la lista valueX.

CASE WHEN condition1 THEN result1 (WHEN condition2 THEN result2)\* (ELSE result\_z) END

Devuelve resultX para la primera condición conditionX que sea TRUE.

NULLIF(value1, value2)

Devuelve NULL si value1 es igual a value2; de lo contrario, devuelve value1.

[COALESCE(value1, value2\[, value3\]\*)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#conditional-functions)

Devuelve el primer valor distinto de NULL entre los argumentos.

IF(condition, true\_value, false\_value)

Devuelve true\_value si condition es TRUE; de lo contrario, devuelve false\_value.

IFNULL(input, null\_replacement)

Devuelve null\_replacement si input es NULL; de lo contrario, devuelve input.

IS_ALPHA(string)

Devuelve TRUE si todos los caracteres de string son letras.

IS_DECIMAL(string)

Devuelve TRUE si string se puede analizar sintácticamente como un número válido.

IS_DIGIT(string)

Devuelve TRUE si todos los caracteres de string son dígitos.

[GREATEST(value1\[, value2\]\*)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#conditional-functions)

Devuelve el valor máximo entre los argumentos. Devuelve NULL si alguna entrada es NULL.

[LEAST(value1\[, value2\]\*)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#conditional-functions)

Devuelve el valor mínimo entre los argumentos. Devuelve NULL si alguna entrada es NULL.

Función

Descripción

CONV

Convierte valores numéricos o caracteres entre distintas bases.

CAST(value AS type)

Convierte value al tipo especificado.

[TYPEOF(input)

TYPEOF(input, force\_serializable)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#type-conversion-functions)

Devuelve la representación en cadena del tipo de datos de input.

Función

Descripción

CARDINALITY(array)

Devuelve el número de elementos de array.

[array\[INT\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#collection-functions)

Devuelve el elemento en la posición INT de array.

ELEMENT(array)

Devuelve el único elemento de array si su cardinalidad es 1.

CARDINALITY(map)

Devuelve el número de entradas de map.

[map\[value\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#collection-functions)

Devuelve el valor asociado a la clave especificada en map.

Función

Descripción

[IS JSON \[{ VALUE

SCALAR

ARRAY

OBJECT }\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#json-functions)

Devuelve TRUE si la entrada es una cadena JSON válida.

[JSON_EXISTS(jsonValue, path \[{ TRUE

FALSE

UNKNOWN

ERROR } ON ERROR\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#json-functions)

Devuelve TRUE si una cadena JSON cumple la condición de ruta especificada.

JSON_STRING(value)

Serializa value en una cadena JSON.

JSON_VALUE

Extrae un valor escalar en la ruta especificada de una cadena JSON.

[JSON_QUERY(jsonValue, path \[wrapper\] \[ON EMPTY\] \[ON ERROR\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#json-functions)

Extrae un valor JSON de una cadena JSON.

[JSON_OBJECT(\[\[KEY\] key VALUE value\]\* \[{ NULL

ABSENT } ON NULL\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#json-functions)

Construye un objeto JSON a partir de pares clave-valor.

[JSON_OBJECTAGG(\[KEY\] key VALUE value \[{ NULL

ABSENT } ON NULL\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#json-functions)

Agrega expresiones clave-valor en un objeto JSON.

[JSON_ARRAY(\[value\]\* \[{ NULL

ABSENT } ON NULL\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#json-functions)

Construye un arreglo JSON a partir de una lista de valores.

[JSON_ARRAYAGG(items \[{ NULL

ABSENT } ON NULL\])](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#json-functions)

Agrega elementos en una cadena de arreglo JSON.

JSON_QUOTE

Envuelve una cadena entre comillas dobles como valor JSON.

JSON_UNQUOTE

Elimina las comillas JSON de un valor.

Función

Descripción

[(value1 \[, value2\]\*)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#value-construction-functions)

Devuelve una fila construida a partir de los valores dados.

[ARRAY\[value1 \[, value2\]\*\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#value-construction-functions)

Devuelve un arreglo construido a partir de los valores dados.

[MAP\[value1, value2 \[, value3, value4\]\*\]](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#value-construction-functions)

Devuelve un mapa construido a partir de los pares clave-valor dados.

Función

Descripción

tableName.compositeType.field

Extrae el valor de un campo de un tipo compuesto, como Tuple o POJO.

tableName.compositeType.\*

Expande un tipo compuesto, como Tuple o POJO, en campos independientes.

Función

Descripción

GROUP_ID()

Devuelve un entero que identifica de forma única una combinación de claves de agrupación.

[GROUPING(expression1 \[, expression2\]\*)

GROUPING_ID(expression1 \[, expression2\]\*)](https://nightlies.apache.org/flink/flink-docs-release-1.17/docs/dev/table/functions/systemfunctions/#grouping-functions)

Devuelve un vector de bits que representa el estado de agrupación de las expresiones dadas.

Función

Descripción

MD5(string)

Devuelve el hash MD5 de string como una cadena hexadecimal de 32 caracteres.

SHA1(string)

Devuelve el hash SHA-1 de string como una cadena hexadecimal de 40 caracteres.

SHA224(string)

Devuelve el hash SHA-224 de string como una cadena hexadecimal de 56 caracteres.

SHA256(string)

Devuelve el hash SHA-256 de string como una cadena hexadecimal de 64 caracteres.

SHA384(string)

Devuelve el hash SHA-384 de string como una cadena hexadecimal de 96 caracteres.

SHA512(string)

Devuelve el hash SHA-512 de string como una cadena hexadecimal de 128 caracteres.

SHA2(string, hashLength)

Devuelve un hash mediante SHA-224, SHA-256, SHA-384 o SHA-512, según hashLength.

MURMUR_HASH

Calcula el hash Murmur de 32 bits de la entrada.

MURMUR_HASH_64

Calcula el hash Murmur de 64 bits de la entrada mediante el algoritmo Murmur 128.

Función

Descripción

ISNAN

Devuelve TRUE si el número de punto flotante especificado es NaN (equivalente a Double.isNaN() o Float.isNaN() en Java).

KEYVALUE

Divide una cadena en pares clave-valor. Utiliza split1 como delimitador de pares y split2 como delimitador de clave-valor. Después, devuelve el valor correspondiente a la clave especificada.