org.apache.drill.exec.store.ischema

Class RecordCollector.MetastoreRecordCollector

java.lang.Object

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

All Implemented Interfaces:

RecordCollector

Enclosing interface:

RecordCollector

public static class RecordCollector.MetastoreRecordCollector
extends Object
implements RecordCollector

Provides information_schema data based on information stored in Drill Metastore.

Nested Class Summary

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

RecordCollector.BasicRecordCollector, RecordCollector.MetastoreRecordCollector

Field Summary

Fields

Modifier and Type	Field and Description
static int	UNDEFINED_INDEX

Constructor Summary

Constructors

Constructor and Description
MetastoreRecordCollector(Metastore metastore, FilterEvaluator filterEvaluator)

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.

Methods inherited from class java.lang.Object

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

Field Detail

UNDEFINED_INDEX

public static final int UNDEFINED_INDEX

See Also:

Constant Field Values

Constructor Detail

MetastoreRecordCollector

public MetastoreRecordCollector(Metastore metastore,
                                FilterEvaluator filterEvaluator)

Method Detail

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