INTEGRITY Документация

← Cloudflare Pipelines / pipelines / sql-reference / scalar-functions

Функции для структур

Реализации скалярных функций Cloudflare Pipelines основаны на Apache DataFusion ↗ (через Arroyo ↗) и эта документация составлена на основе справочника функций DataFusion.

struct

Возвращает Arrow-структуру на основе указанных входных выражений. Поля возвращаемой структуры используют cN соглашением об именовании. Например: c0, c1, c2, и т. д.

struct(expression1[, ..., expression_n])

Например, следующий запрос преобразует два столбца a и b в один столбец с типом struct и полями c0 и c1:

select * from t;
+---+---+
| a | b |
+---+---+
| 1 | 2 |
| 3 | 4 |
+---+---+

select struct(a, b) from t;
+-----------------+
| struct(t.a,t.b) |
+-----------------+
| {c0: 1, c1: 2}  |
| {c0: 3, c1: 4}  |
+-----------------+

Аргументы