org.apache.drill.exec.store.ischema

Interface RecordCollector

All Known Implementing Classes:

RecordCollector.BasicRecordCollector, RecordCollector.MetastoreRecordCollector

public interface RecordCollector

Provides methods to collect various information_schema data.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static class	RecordCollector.BasicRecordCollector Provides information_schema data based on information stored in AbstractSchema.
static class	RecordCollector.MetastoreRecordCollector Provides information_schema data based on information stored in Drill Metastore.

Method Summary

Modifier and Type	Method and 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.

Method Detail

catalogs

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

Collects catalogs data for information_schema.

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of catalog records

schemas

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

Collects schemas data for information_schema.

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of schema records

tables

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

Collects tables data for information_schema.

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of table records

views

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

Collects views data for information_schema.

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of view records

columns

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

Collects columns data for information_schema.

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of column records

partitions

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

Collects partitions data for information_schema.

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of partition records

files

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

Collects files data for information_schema.

Parameters:

schemaPath - schema name

schema - schema instance

Returns:

list of file records