Агрегатная функция schema_of_json_agg
Область применения: Databricks SQL Databricks Runtime 13.2 и более поздних версий
Возвращает объединенную схему всех строк JSON в группе в формате DDL.
Синтаксис
schema_of_json_agg(jsonStr [, options] ) [FILTER ( WHERE cond ) ]
Эту функцию также можно вызвать как функцию окна с помощью OVER
предложения.
Аргументы
jsonStr
: литералSTRING
сJSON
.options
: необязательныйMAP
литерал с ключами и значениямиSTRING
. Дополнительные сведения о параметрах см. в статье Функция from_json.cond
: необязательноеBOOLEAN
выражение, фильтрующее строки, используемые для агрегирования.
Возвраты
Определение STRING
массива структур с n
полями строк, в которых имена столбцов являются производными от определенного набора ключей JSON
.
Значения полей содержат производные отформатированные типы SQL.
Схема каждой записи объединяется по имени поля.
Если два поля с одинаковым именем имеют другой тип в записях, Azure Databricks использует наименее распространенный тип.
Если такой тип не существует, тип является производным как .STRING
Например, и стать, а STRING
STRUCT<i INT>
также статьSTRING
.DOUBLE
DOUBLE
INT
Схема, полученная из чтения столбца JSON
данных, совпадает с схемой, полученной из следующего.
SELECT * FROM json.`/my/data`;
Чтобы получить схему одной JSON
строки, используйте функцию schema_of_json.
Примеры
> SELECT schema_of_json_agg(a) FROM VALUES('{"foo": "bar"}') AS data(a);
STRUCT<foo: STRING>
> SELECT schema_of_json_agg(a) FROM VALUES('[1]') AS data(a);
ARRAY<BIGINT>
> CREATE TEMPORARY VIEW data(a) AS VALUES
('{"foo": "bar", "wing": {"ding": "dong"}}'),
('{"top": "level", "wing": {"stop": "go"}}')
> SELECT schema_of_json_agg(a) FROM data;
STRUCT<foo: STRING,top: STRING,wing: STRUCT<ding: STRING, stop: STRING>>