Package org.apache.drill.exec.store.ischema

Class RecordCollector.BasicRecordCollector

java.lang.Object

org.apache.drill.exec.store.ischema.RecordCollector.BasicRecordCollector

All Implemented Interfaces:

RecordCollector

Enclosing interface:

RecordCollector

public static class RecordCollector.BasicRecordCollector
extends Object
implements RecordCollector

Provides information_schema data based on information stored in AbstractSchema.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.store.ischema.RecordCollector

RecordCollector.BasicRecordCollector, RecordCollector.MetastoreRecordCollector

Constructor Summary

Constructors

Constructor	Description
BasicRecordCollector(FilterEvaluator filterEvaluator, OptionManager optionManager)

Method Summary

Modifier and Type	Method	Description
List<Records.Catalog>	catalogs(String schemaPath, org.apache.calcite.schema.SchemaPlus schema)	Collects catalogs data for information_schema.
List<Records.Column>	columns(String schemaPath, org.apache.calcite.schema.SchemaPlus schema)	Collects columns data for information_schema.
List<Records.File>	files(String schemaPath, org.apache.calcite.schema.SchemaPlus schema)	Collects files data for information_schema.
List<Records.Partition>	partitions(String schemaPath, org.apache.calcite.schema.SchemaPlus schema)	Collects partitions data for information_schema.
List<Records.Schema>	schemas(String schemaPath, org.apache.calcite.schema.SchemaPlus schema)	Collects schemas data for information_schema.
List<Records.Table>	tables(String schemaPath, org.apache.calcite.schema.SchemaPlus schema)	Collects tables data for information_schema.
List<Records.View>	views(String schemaPath, org.apache.calcite.schema.SchemaPlus schema)	Collects views data for information_schema.

Methods inherited from class java.lang.Object

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

Constructor Details

BasicRecordCollector

public BasicRecordCollector(FilterEvaluator filterEvaluator,
 OptionManager optionManager)

Method Details

catalogs

public List<Records.Catalog> catalogs(String schemaPath,
 org.apache.calcite.schema.SchemaPlus schema)

Description copied from interface: RecordCollector

Collects catalogs data for information_schema.

Specified by:

catalogs in interface RecordCollector

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of catalog records

schemas

public List<Records.Schema> schemas(String schemaPath,
 org.apache.calcite.schema.SchemaPlus schema)

Description copied from interface: RecordCollector

Collects schemas data for information_schema.

Specified by:

schemas in interface RecordCollector

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of schema records

tables

public List<Records.Table> tables(String schemaPath,
 org.apache.calcite.schema.SchemaPlus schema)

Description copied from interface: RecordCollector

Collects tables data for information_schema.

Specified by:

tables in interface RecordCollector

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of table records

views

public List<Records.View> views(String schemaPath,
 org.apache.calcite.schema.SchemaPlus schema)

Description copied from interface: RecordCollector

Collects views data for information_schema.

Specified by:

views in interface RecordCollector

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of view records

columns

public List<Records.Column> columns(String schemaPath,
 org.apache.calcite.schema.SchemaPlus schema)

Description copied from interface: RecordCollector

Collects columns data for information_schema.

Specified by:

columns in interface RecordCollector

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of column records

partitions

public List<Records.Partition> partitions(String schemaPath,
 org.apache.calcite.schema.SchemaPlus schema)

Description copied from interface: RecordCollector

Collects partitions data for information_schema.

Specified by:

partitions in interface RecordCollector

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of partition records

files

public List<Records.File> files(String schemaPath,
 org.apache.calcite.schema.SchemaPlus schema)

Description copied from interface: RecordCollector

Collects files data for information_schema.

Specified by:

files in interface RecordCollector

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of file records