org.apache.drill.exec.store.easy.json.loader

Class BaseFieldFactory

java.lang.Object

org.apache.drill.exec.store.easy.json.loader.BaseFieldFactory

All Implemented Interfaces:

FieldFactory

Direct Known Subclasses:

ExtendedTypeFieldFactory, InferredFieldFactory, ProvidedFieldFactory

public abstract class BaseFieldFactory
extends Object
implements FieldFactory

Base field factor class which handles the common tasks for building column writers and JSON listeners.

Field Summary

Fields

Modifier and Type	Field and Description
protected FieldFactory	child
protected JsonLoaderImpl	loader

Constructor Summary

Constructors

Constructor and Description
BaseFieldFactory(JsonLoaderImpl loader)
BaseFieldFactory(JsonLoaderImpl loader, FieldFactory child)

Method Summary

Modifier and Type	Method and Description
ElementParser	buildOuterArrays(ObjectWriter writer, int dims, Function<ObjectWriter,ElementParser> innerCreator) Create layers of repeated list listeners around the type-specific array.
ElementParser	forceArrayResolution(FieldDefn fieldDefn)
ElementParser	forceNullResolution(FieldDefn fieldDefn)
ElementParser	ignoredFieldParser()
protected JsonLoaderImpl	loader()
ElementParser	multiDimObjectArrayFor(ObjectWriter writer, int dims, TupleMetadata providedSchema) Create a repeated list listener for a Map.
protected ElementParser	multiDimScalarArrayFor(ObjectWriter writer, int dims) Create a repeated list listener for a scalar value.
protected ElementParser	multiDimVariantArrayParserFor(ObjectWriter writer, int dims) Create a repeated list listener for a variant.
protected ElementParser	objectArrayParserFor(ArrayWriter arrayWriter, TupleMetadata providedSchema)
protected ElementParser	objectArrayParserFor(FieldDefn fieldDefn, ColumnMetadata colSchema, TupleMetadata providedSchema) Create a map array column and its associated parsers and listeners for the given column schema and optional provided schema.
ElementParser	objectParserFor(FieldDefn fieldDefn) Create a map column and its associated object value listener for the a JSON object value given the value's key.
protected ElementParser	objectParserFor(FieldDefn fieldDefn, ColumnMetadata colSchema, TupleMetadata providedSchema) Create a map column and its associated object value listener for the given key and optional provided schema.
protected ElementParser	objectParserFor(TupleWriter writer, TupleMetadata providedSchema)
protected FieldParserFactory	parserFactory()
protected ColumnMetadata	repeatedListSchemaFor(String key, int dims, ColumnMetadata innerArray) Build up a repeated list column definition given a specification of the number of dimensions and the JSON type.
protected ElementParser	scalarArrayParserFor(ArrayWriter writer)
protected ElementParser	scalarArrayParserFor(ValueParser element)
ScalarListener	scalarListenerFor(ScalarWriter writer)
ValueParser	scalarParserFor(FieldDefn fieldDefn, ColumnMetadata colSchema) Internal method which allows a custom parser (such as for extended types) to provide the scalar parser for a provided schema.
ValueParser	scalarParserFor(ScalarWriter writer)
protected ElementParser	variantArrayParserFor(ArrayWriter arrayWriter) Create a variant array (LIST) column and its associated parser given a column schema.
protected ElementParser	variantParserFor(VariantWriter writer) Create a variant (UNION) column and its associated parser given a column schema.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.store.easy.json.loader.FieldFactory

fieldParser

Field Detail

loader

protected final JsonLoaderImpl loader

child

protected final FieldFactory child

Constructor Detail

BaseFieldFactory

public BaseFieldFactory(JsonLoaderImpl loader)

BaseFieldFactory

public BaseFieldFactory(JsonLoaderImpl loader,
                        FieldFactory child)

Method Detail

parserFactory

protected FieldParserFactory parserFactory()

ignoredFieldParser

public ElementParser ignoredFieldParser()

Specified by:

ignoredFieldParser in interface FieldFactory

loader

protected JsonLoaderImpl loader()

scalarParserFor

public ValueParser scalarParserFor(FieldDefn fieldDefn,
                                   ColumnMetadata colSchema)

Description copied from interface: FieldFactory

Internal method which allows a custom parser (such as for extended types) to provide the scalar parser for a provided schema.

Specified by:

scalarParserFor in interface FieldFactory

scalarParserFor

public ValueParser scalarParserFor(ScalarWriter writer)

scalarArrayParserFor

protected ElementParser scalarArrayParserFor(ValueParser element)

scalarArrayParserFor

protected ElementParser scalarArrayParserFor(ArrayWriter writer)

multiDimScalarArrayFor

protected ElementParser multiDimScalarArrayFor(ObjectWriter writer,
                                               int dims)

Create a repeated list listener for a scalar value.

objectParserFor

public ElementParser objectParserFor(FieldDefn fieldDefn)

Create a map column and its associated object value listener for the a JSON object value given the value's key.

objectParserFor

protected ElementParser objectParserFor(FieldDefn fieldDefn,
                                        ColumnMetadata colSchema,
                                        TupleMetadata providedSchema)

Create a map column and its associated object value listener for the given key and optional provided schema.

objectArrayParserFor

protected ElementParser objectArrayParserFor(FieldDefn fieldDefn,
                                             ColumnMetadata colSchema,
                                             TupleMetadata providedSchema)

Create a map array column and its associated parsers and listeners for the given column schema and optional provided schema.

objectArrayParserFor

protected ElementParser objectArrayParserFor(ArrayWriter arrayWriter,
                                             TupleMetadata providedSchema)

objectParserFor

protected ElementParser objectParserFor(TupleWriter writer,
                                        TupleMetadata providedSchema)

multiDimObjectArrayFor

public ElementParser multiDimObjectArrayFor(ObjectWriter writer,
                                            int dims,
                                            TupleMetadata providedSchema)

Create a repeated list listener for a Map.

variantParserFor

protected ElementParser variantParserFor(VariantWriter writer)

Create a variant (UNION) column and its associated parser given a column schema.

variantArrayParserFor

protected ElementParser variantArrayParserFor(ArrayWriter arrayWriter)

Create a variant array (LIST) column and its associated parser given a column schema.

multiDimVariantArrayParserFor

protected ElementParser multiDimVariantArrayParserFor(ObjectWriter writer,
                                                      int dims)

Create a repeated list listener for a variant. Here, the inner array is provided by a List (which is a repeated Union.)

buildOuterArrays

public ElementParser buildOuterArrays(ObjectWriter writer,
                                      int dims,
                                      Function<ObjectWriter,ElementParser> innerCreator)

Create layers of repeated list listeners around the type-specific array. If the JSON has three array levels, the outer two are repeated lists, the inner is type-specific: say an array of BIGINT or a map array.

repeatedListSchemaFor

protected ColumnMetadata repeatedListSchemaFor(String key,
                                               int dims,
                                               ColumnMetadata innerArray)

Build up a repeated list column definition given a specification of the number of dimensions and the JSON type. Creation of the element type is via a closure that builds the needed schema.

scalarListenerFor

public ScalarListener scalarListenerFor(ScalarWriter writer)

forceNullResolution

public ElementParser forceNullResolution(FieldDefn fieldDefn)

Specified by:

forceNullResolution in interface FieldFactory

forceArrayResolution

public ElementParser forceArrayResolution(FieldDefn fieldDefn)

Specified by:

forceArrayResolution in interface FieldFactory