다음을 통해 공유

from_avro 기능

  • 아티클

적용 대상:유효성 검사 체크 후 예, Databricks Runtime 16.0 이상

avroBin 및 jsonSchemaStr가 있는 구조체 값을 반환합니다.

구문

from_avro(avroBin, jsonSchemaStr [, options] )

인수

  • avroBin BINARY: Avro 데이터의 행을 지정하는 식입니다.
  • avroSchemaSpec: JSON 형식의 대상 스키마입니다. to_avro()에 avroBin 지정된 대로 인코딩된 스키마와 일치해야 합니다.
  • options: 지시문을 지정하는 선택적 MAP<STRING,STRING> 리터럴입니다.

반품

schema_of_json(jsonStr)STRUCT결과를 기반으로 필드 이름 및 형식이 있는 A 입니다.

avroBin 는 잘 구성 avroSchemaSpec 되어야 하며 options Databricks는 예외를 발생시켜야 합니다.

주의

가장 일반적으로 지원되는 옵션은 다음과 같습니다.

옵션 값 설명
'mode' 'PERMISSIVE', 'FAILFAST' 모드에서 PERMISSIVE 개체의 손상된 개체 또는 필드는 오류를 발생시키는 NULL 대신 설정됩니다.
compression 'uncompressed', 'snappy''deflade', 'bzip2', , 'xz''zstandard' Avro 데이터를 인코딩하는 데 사용되는 압축 코덱을 지정합니다.

자세한 옵션은 스트리밍 Avro 데이터 읽기 및 쓰기를 참조 하세요.

예제

> 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"}

> SELECT from_avro(to_avro(named_struct('num', 5, 'txt', 'hello')),
                   '{ "type" : "record", "name": "my_record", "fields": [{ "name": "num", "type": "int"}, { "name": "txt", "type": "double"}]}',
                   map('mode', 'failfast'));
  Error: Avro data is not valid for the specified schema.

> SELECT from_avro(to_avro(named_struct('num', 5, 'txt', 'hello')),
                   '{ "type" : "record", "name": "my_record", "fields": [{ "name": "num", "type": "int"}, { "name": "txt", "type": "double"}]}',
                   map('mode', 'permissive'));
  {"num":null,"txt":null}