Package 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	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	Description
protected List<S>	records

Constructor Summary

Constructors

Constructor	Description
InfoSchemaRecordGenerator(FilterEvaluator filterEvaluator)

Method Summary

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

records

protected List<S> records

Constructor Details

InfoSchemaRecordGenerator

public InfoSchemaRecordGenerator(FilterEvaluator filterEvaluator)

Method Details

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)