org.apache.drill.exec.store.ischema

Class InfoSchemaRecordGenerator.Catalogs

java.lang.Object

org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator<Records.Catalog>

org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator.Catalogs

Enclosing class:

InfoSchemaRecordGenerator<S>

public static class InfoSchemaRecordGenerator.Catalogs
extends InfoSchemaRecordGenerator<Records.Catalog>

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator

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

Field Summary

Fields inherited from class org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator

records

Constructor Summary

Constructors

Constructor and Description
Catalogs(FilterEvaluator filterEvaluator)

Method Summary

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

Methods inherited from class org.apache.drill.exec.store.ischema.InfoSchemaRecordGenerator

registerRecordCollector, scanSchema, visit

Methods inherited from class java.lang.Object

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

Constructor Detail

Catalogs

public Catalogs(FilterEvaluator filterEvaluator)

Method Detail

getRecordReader

public PojoRecordReader<Records.Catalog> getRecordReader()

Specified by:

getRecordReader in class InfoSchemaRecordGenerator<Records.Catalog>

collect

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

Specified by:

collect in class InfoSchemaRecordGenerator<Records.Catalog>

scanSchema

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

Description copied from class: InfoSchemaRecordGenerator

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

Overrides:

scanSchema in class InfoSchemaRecordGenerator<Records.Catalog>

Parameters:

schemaPath - the path to the given schema, so far

schema - the given schema