org.apache.drill.exec.physical.impl.scan.project

Class NullColumnBuilder

java.lang.Object

org.apache.drill.exec.physical.impl.scan.project.NullColumnBuilder

All Implemented Interfaces:

VectorSource

public class NullColumnBuilder
extends Object
implements VectorSource

Manages null columns by creating a null column loader for each set of non-empty null columns. This class acts as a scan-wide facade around the per-schema null column loader.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	NullColumnBuilder.NullBuilderBuilder

Field Summary

Fields

Modifier and Type	Field and Description
protected List<NullColumnLoader.NullColumnSpec>	nullCols Creates null columns if needed.
protected TupleMetadata	outputSchema

Constructor Summary

Constructors

Constructor and Description
NullColumnBuilder(NullColumnBuilder.NullBuilderBuilder builder)

Method Summary

Modifier and Type	Method and Description
ResolvedNullColumn	add(ColumnMetadata colDefn)
ResolvedNullColumn	add(String name)
ResolvedNullColumn	add(String name, TypeProtos.MajorType type)
void	build(ResultVectorCache vectorCache)
void	close()
boolean	hasColumns()
void	load(int rowCount)
NullColumnBuilder	newChild(String mapName)
VectorContainer	output()
ValueVector	vector(int index)

Methods inherited from class java.lang.Object

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

Field Detail

nullCols

protected final List<NullColumnLoader.NullColumnSpec> nullCols

Creates null columns if needed.

outputSchema

protected TupleMetadata outputSchema

Constructor Detail

NullColumnBuilder

public NullColumnBuilder(NullColumnBuilder.NullBuilderBuilder builder)

Method Detail

newChild

public NullColumnBuilder newChild(String mapName)

add

public ResolvedNullColumn add(String name)

add

public ResolvedNullColumn add(ColumnMetadata colDefn)

add

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

build

public void build(ResultVectorCache vectorCache)

hasColumns

public boolean hasColumns()

load

public void load(int rowCount)

vector

public ValueVector vector(int index)

Specified by:

vector in interface VectorSource

output

public VectorContainer output()

close

public void close()