Todos los productos
Search
Centro de documentos

Realtime Compute for Apache Flink:PARSE_JSON

Última actualización: Sep 03, 2026

Convierte una cadena JSON en un valor VARIANT.

Nota

Esta función solo es compatible con Ververica Runtime (VVR) 11.1.0 o versiones posteriores.

Sintaxis

VARIANT PARSE_JSON(VARCHAR jsonStr [, BOOLEAN allowDuplicateKeys])

Argumentos

Argumento

Tipo de dato

Descripción

jsonStr

VARCHAR

Cadena JSON para analizar.

allowDuplicateKeys

BOOLEAN

(Opcional) Indica si se permiten claves duplicadas. true: conserva el valor de la última clave duplicada. false (predeterminado): genera un error si existen claves duplicadas.

Notas de uso

  • Si jsonStr es NULL, la función devuelve NULL.

PARSE_JSON frente a TRY_PARSE_JSON

Función

Manejo de errores

Valor de retorno para JSON no válido

Cuándo utilizarla

PARSE_JSON

Genera un error

Error

Se requiere validación estricta de entrada

TRY_PARSE_JSON

Tolera errores

NULL

Se aceptan entradas no válidas

Ejemplos

Uso básico

Tabla de entrada T1:

jsonString (VARCHAR)

{"k": "v1", "k2": 1}

SELECT PARSE_JSON(jsonString) AS v
FROM T1;

Resultado:

v (VARIANT)

{"k": "v1", "k2": 1}

Manejo de claves duplicadas

De forma predeterminada, PARSE_JSON genera un error cuando hay claves duplicadas:

SELECT PARSE_JSON('{"a": "123", "b": "456", "a": "789"}') AS v;

Para conservar el último valor de cada clave duplicada, establezca allowDuplicateKeys en true:

SELECT PARSE_JSON('{"a": "123", "b": "456", "a": "789"}', true) AS v;