Package org.apache.drill.exec.store.avro

Class AvroSchemaUtil

java.lang.Object

org.apache.drill.exec.store.avro.AvroSchemaUtil

public class AvroSchemaUtil
extends Object

Utility class that provides methods to interact with Avro schema.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	AVRO_LOGICAL_TYPE_PROPERTY
static final String	DATE_LOGICAL_TYPE
static final String	DECIMAL_LOGICAL_TYPE
static final String	DURATION_LOGICAL_TYPE
static final String	TIME_MICROS_LOGICAL_TYPE
static final String	TIME_MILLIS_LOGICAL_TYPE
static final String	TIMESTAMP_MICROS_LOGICAL_TYPE
static final String	TIMESTAMP_MILLIS_LOGICAL_TYPE

Constructor Summary

Constructors

Constructor	Description
AvroSchemaUtil()

Method Summary

Modifier and Type	Method	Description
static TupleMetadata	convert(org.apache.avro.Schema schema)	Converts Avro schema into Drill metadata description of the schema.
static org.apache.avro.Schema	extractSchemaFromNullable(org.apache.avro.Schema schema, String columnName)	Avro represents nullable type as union of null and another schema: ["null", "some-type"].

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

AVRO_LOGICAL_TYPE_PROPERTY

public static final String AVRO_LOGICAL_TYPE_PROPERTY

See Also:

• Constant Field Values

DECIMAL_LOGICAL_TYPE

public static final String DECIMAL_LOGICAL_TYPE

See Also:

• Constant Field Values

TIMESTAMP_MICROS_LOGICAL_TYPE

public static final String TIMESTAMP_MICROS_LOGICAL_TYPE

See Also:

• Constant Field Values

TIMESTAMP_MILLIS_LOGICAL_TYPE

public static final String TIMESTAMP_MILLIS_LOGICAL_TYPE

See Also:

• Constant Field Values

DATE_LOGICAL_TYPE

public static final String DATE_LOGICAL_TYPE

See Also:

• Constant Field Values

TIME_MICROS_LOGICAL_TYPE

public static final String TIME_MICROS_LOGICAL_TYPE

See Also:

• Constant Field Values

TIME_MILLIS_LOGICAL_TYPE

public static final String TIME_MILLIS_LOGICAL_TYPE

See Also:

• Constant Field Values

DURATION_LOGICAL_TYPE

public static final String DURATION_LOGICAL_TYPE

See Also:

• Constant Field Values

Constructor Details

AvroSchemaUtil

public AvroSchemaUtil()

Method Details

convert

public static TupleMetadata convert(org.apache.avro.Schema schema)

Converts Avro schema into Drill metadata description of the schema.

Parameters:

schema - Avro schema

Returns:

metadata description of the schema

Throws:

UserException - if schema contains unsupported types

extractSchemaFromNullable

public static org.apache.avro.Schema extractSchemaFromNullable(org.apache.avro.Schema schema,
 String columnName)

Avro represents nullable type as union of null and another schema: ["null", "some-type"]. This method extracts non-nullable schema for given union schema.

Parameters:

schema - Avro schema

columnName - column name

Returns:

non-nullable Avro schema

Throws:

UserException - if given schema is not a union or represents complex union