org.apache.drill.exec.store.ischema

Class InfoSchemaRecordGenerator<S>

java.lang.Object

org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator<S>

Direct Known Subclasses:

InfoSchemaRecordGenerator.Catalogs, InfoSchemaRecordGenerator.Columns, InfoSchemaRecordGenerator.Files, InfoSchemaRecordGenerator.Partitions, InfoSchemaRecordGenerator.Schemata, InfoSchemaRecordGenerator.Tables, InfoSchemaRecordGenerator.Views

public abstract class InfoSchemaRecordGenerator<S>
extends Object

Generates records for POJO RecordReader by scanning the given schema. At every level (catalog, schema, table, field, partition, file), level specific object is visited and decision is taken to visit the contents of the object. Object here is catalog, schema, table, field, partition, file.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	InfoSchemaRecordGenerator.Catalogs
static class	InfoSchemaRecordGenerator.Columns
static class	InfoSchemaRecordGenerator.Files
static class	InfoSchemaRecordGenerator.Partitions
static class	InfoSchemaRecordGenerator.Schemata
static class	InfoSchemaRecordGenerator.Tables
static class	InfoSchemaRecordGenerator.Views

Field Summary

Fields

Modifier and Type	Field and Description
protected List<S>	records

Constructor Summary

Constructors

Constructor and Description
InfoSchemaRecordGenerator(FilterEvaluator filterEvaluator)

Method Summary

Modifier and Type	Method and Description
protected abstract List<S>	collect(RecordCollector recordCollector, String schemaPath, org.apache.calcite.schema.SchemaPlus schema)
abstract PojoRecordReader<S>	getRecordReader()
void	registerRecordCollector(RecordCollector recordCollector)
void	scanSchema(org.apache.calcite.schema.SchemaPlus root)
protected void	scanSchema(String schemaPath, org.apache.calcite.schema.SchemaPlus schema) Recursively scans the given schema, invoking the visitor as appropriate.
protected void	visit(String schemaPath, org.apache.calcite.schema.SchemaPlus schema)

Methods inherited from class java.lang.Object

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

Field Detail

records

protected List<S> records

Constructor Detail

InfoSchemaRecordGenerator

public InfoSchemaRecordGenerator(FilterEvaluator filterEvaluator)

Method Detail

registerRecordCollector

public void registerRecordCollector(RecordCollector recordCollector)

scanSchema

public void scanSchema(org.apache.calcite.schema.SchemaPlus root)

scanSchema

protected void scanSchema(String schemaPath,
                          org.apache.calcite.schema.SchemaPlus schema)

Recursively scans the given schema, invoking the visitor as appropriate.

Parameters:

schemaPath - the path to the given schema, so far

schema - the given schema

visit

protected final void visit(String schemaPath,
                           org.apache.calcite.schema.SchemaPlus schema)

getRecordReader

public abstract PojoRecordReader<S> getRecordReader()

collect

protected abstract List<S> collect(RecordCollector recordCollector,
                                   String schemaPath,
                                   org.apache.calcite.schema.SchemaPlus schema)