org.apache.drill.exec.record.metadata

Class MapBuilder

java.lang.Object

org.apache.drill.exec.record.metadata.MapBuilder

public class MapBuilder
extends Object

Internal structure for building a map. A map is just a schema, but one that is part of a parent column.

Class can be created with and without parent container. In the first case, column is added to the parent container during creation and all resumeXXX methods return qualified parent container. In the second case column is created without parent container as standalone entity. All resumeXXX methods do not produce any action and return null. To access built column buildColumn() should be used.

Constructor Summary

Constructors

Constructor and Description
MapBuilder(org.apache.drill.exec.record.metadata.SchemaContainer parent, String memberName, TypeProtos.DataMode mode)
MapBuilder(String memberName, TypeProtos.DataMode mode)

Method Summary

Modifier and Type	Method and Description
MapBuilder	add(MaterializedField col)
MapBuilder	add(String name, TypeProtos.MajorType type)
MapBuilder	add(String name, TypeProtos.MinorType type)
MapBuilder	add(String name, TypeProtos.MinorType type, int width)
MapBuilder	add(String name, TypeProtos.MinorType type, int precision, int scale)
MapBuilder	add(String name, TypeProtos.MinorType type, TypeProtos.DataMode mode)
MapBuilder	addArray(String name, TypeProtos.MinorType type)
MapBuilder	addArray(String name, TypeProtos.MinorType type, int dims)
MapBuilder	addArray(String name, TypeProtos.MinorType type, int precision, int scale)
void	addColumn(ColumnMetadata column)
MapBuilder	addDecimal(String name, TypeProtos.MinorType type, TypeProtos.DataMode mode, int precision, int scale)
DictBuilder	addDict(String name, TypeProtos.MajorType keyType)
DictBuilder	addDict(String name, TypeProtos.MinorType keyType)
DictBuilder	addDictArray(String name, TypeProtos.MajorType keyType)
DictBuilder	addDictArray(String name, TypeProtos.MinorType keyType)
MapBuilder	addDynamic(String name)
UnionBuilder	addList(String name)
MapBuilder	addMap(String name) Add a map column.
MapBuilder	addMapArray(String name)
MapBuilder	addNullable(String name, TypeProtos.MinorType type)
MapBuilder	addNullable(String name, TypeProtos.MinorType type, int width)
MapBuilder	addNullable(String name, TypeProtos.MinorType type, int precision, int scale)
RepeatedListBuilder	addRepeatedList(String name)
UnionBuilder	addUnion(String name)
void	build()
MapColumnMetadata	buildColumn()
DictBuilder	resumeDict()
RepeatedListBuilder	resumeList()
MapBuilder	resumeMap()
SchemaBuilder	resumeSchema()
UnionBuilder	resumeUnion()

Methods inherited from class java.lang.Object

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

Constructor Detail

MapBuilder

public MapBuilder(String memberName,
                  TypeProtos.DataMode mode)

MapBuilder

public MapBuilder(org.apache.drill.exec.record.metadata.SchemaContainer parent,
                  String memberName,
                  TypeProtos.DataMode mode)

Method Detail

addColumn

public void addColumn(ColumnMetadata column)

add

public MapBuilder add(String name,
                      TypeProtos.MajorType type)

add

public MapBuilder add(MaterializedField col)

add

public MapBuilder add(String name,
                      TypeProtos.MinorType type,
                      TypeProtos.DataMode mode)

add

public MapBuilder add(String name,
                      TypeProtos.MinorType type)

add

public MapBuilder add(String name,
                      TypeProtos.MinorType type,
                      int width)

add

public MapBuilder add(String name,
                      TypeProtos.MinorType type,
                      int precision,
                      int scale)

addNullable

public MapBuilder addNullable(String name,
                              TypeProtos.MinorType type)

addNullable

public MapBuilder addNullable(String name,
                              TypeProtos.MinorType type,
                              int width)

addNullable

public MapBuilder addNullable(String name,
                              TypeProtos.MinorType type,
                              int precision,
                              int scale)

addArray

public MapBuilder addArray(String name,
                           TypeProtos.MinorType type)

addArray

public MapBuilder addArray(String name,
                           TypeProtos.MinorType type,
                           int dims)

addArray

public MapBuilder addArray(String name,
                           TypeProtos.MinorType type,
                           int precision,
                           int scale)

addDynamic

public MapBuilder addDynamic(String name)

addDecimal

public MapBuilder addDecimal(String name,
                             TypeProtos.MinorType type,
                             TypeProtos.DataMode mode,
                             int precision,
                             int scale)

addMap

public MapBuilder addMap(String name)

Add a map column. The returned schema builder is for the nested map. Building that map, using resumeSchema(), will return the original schema builder.

Parameters:

name - the name of the map column

Returns:

a builder for the map

addMapArray

public MapBuilder addMapArray(String name)

addUnion

public UnionBuilder addUnion(String name)

addList

public UnionBuilder addList(String name)

addRepeatedList

public RepeatedListBuilder addRepeatedList(String name)

addDict

public DictBuilder addDict(String name,
                           TypeProtos.MinorType keyType)

addDict

public DictBuilder addDict(String name,
                           TypeProtos.MajorType keyType)

addDictArray

public DictBuilder addDictArray(String name,
                                TypeProtos.MinorType keyType)

addDictArray

public DictBuilder addDictArray(String name,
                                TypeProtos.MajorType keyType)

buildColumn

public MapColumnMetadata buildColumn()

build

public void build()

resumeSchema

public SchemaBuilder resumeSchema()

resumeMap

public MapBuilder resumeMap()

resumeList

public RepeatedListBuilder resumeList()

resumeUnion

public UnionBuilder resumeUnion()

resumeDict

public DictBuilder resumeDict()