Package 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	Description
static final int	UNDEFINED_INDEX

Constructor Summary

Constructors

Constructor	Description
MetastoreRecordCollector(Metastore metastore, FilterEvaluator filterEvaluator)

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

Field Details

UNDEFINED_INDEX

public static final int UNDEFINED_INDEX

See Also:

• Constant Field Values

Constructor Details

MetastoreRecordCollector

public MetastoreRecordCollector(Metastore metastore,
 FilterEvaluator filterEvaluator)

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