to_avro 関数
適用対象: 
Databricks SQL Databricks Runtime 15.4 以降
指定した入力値を持つ Avro バイナリ値を返します。
構文
to_avro(expr [, avroSchemaSpec] )
引数
expr: 式。avroSchemaSpec: JSON 形式の省略可能なターゲット スキーマ。 指定した場合は、Notes で指定されたexpr型と一致する必要があります。
返品
Avro でエンコードされた BINARY。
メモ
Avro 型への SQL 型のマッピングは次のとおりです。
| SQL 型 | Avro スキーマ |
|---|---|
VOID |
{ "type" : "null" } |
BOOLEAN |
{ "type" : "boolean" } |
TINYINT |
{ "type" : "int" } |
SMALLINT |
{ "type" : "int" } |
INT |
{ "type" : "int" } |
BIGINT |
{ "type" : "long" } |
DECIMAL(p, s) |
{ "type": "fixed", "name": "a", logicalType": "decimal", "size": (p+1)/2, precision": p, "scale": s } |
FLOAT |
{ "type" : "float" } |
DOUBLE |
{ "type" : "float" } |
STRING |
{ "type" : "string" } |
DATE |
{ "type" : "int", "logicalType" : "date" } |
TIMESTAMP |
{ "type" : "long" } 以降のマイクロ秒 1970-01-01 00:00:00.000000 |
TIMESTAMP_NTZ |
{ "type" : "long" } 以降のマイクロ秒 1970-01-01 00:00:00.000000 |
YEAR MONTH INTERVAL |
{ "type" : "long" } 月単位 |
DAY TIME INTERVAL |
{ "type" : "long" } マイクロ秒 |
BINARY |
{ "type" : "bytes" } |
STRUCT<field1 type1, ...> |
{ "type" : "record", "name": "struct_name", "fields": [ { "name" : "field1", "type" : ... }, ... ] } |
ARRAY<type> |
{ "type" : "array", "items": { "type" : ... } |
MAP<STRING, valueType> |
{ "type" : "map", "keyType": { "type" : ... }, "valueType": { "type" : ... } } |
MAP<nonStringType, valueType> |
サポート対象外 |
VARIANT |
サポート対象外 |
例
> SELECT from_avro(to_avro(5), '{ "type" : "int" }');
5
> SELECT from_avro(to_avro(5, '{ "type" : "int" }'), '{ "type" : "int" }');
5
> SELECT from_avro(to_avro(named_struct('num', 5, 'txt', 'hello')), '{ "type" : "record", "name": "my_record", "fields": [{ "name": "num", "type": "int"}, { "name": "txt", "type": "string"}]}');
{"num":5,"txt":"hello"}