Package org.apache.drill.metastore.rdbms.components.tables

Class TablesMetadataMapper.PartitionMapper

java.lang.Object

org.apache.drill.metastore.rdbms.transform.AbstractMetadataMapper<TableMetadataUnit,R>

org.apache.drill.metastore.rdbms.components.tables.TablesMetadataMapper<PartitionsRecord>

org.apache.drill.metastore.rdbms.components.tables.TablesMetadataMapper.PartitionMapper

All Implemented Interfaces:

MetadataMapper<TableMetadataUnit,PartitionsRecord>

Enclosing class:

TablesMetadataMapper<R extends org.jooq.Record>

public static class TablesMetadataMapper.PartitionMapper
extends TablesMetadataMapper<PartitionsRecord>

TablesMetadataMapper implementation for Tables.PARTITIONS table.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.drill.metastore.rdbms.components.tables.TablesMetadataMapper

TablesMetadataMapper.FileMapper, TablesMetadataMapper.PartitionMapper, TablesMetadataMapper.RowGroupMapper, TablesMetadataMapper.SegmentMapper, TablesMetadataMapper.TableMapper

Field Summary

Fields inherited from class org.apache.drill.metastore.rdbms.components.tables.TablesMetadataMapper

COMPONENT_PARTITION_KEY, TABLE_PARTITION_KEY

Constructor Summary

Constructors

Constructor	Description
PartitionMapper()

Method Summary

Modifier and Type	Method	Description
protected Map<MetastoreColumn,org.jooq.Field<?>>	fieldMapper()
protected RdbmsFilterExpressionVisitor	filterVisitor()
static TablesMetadataMapper.PartitionMapper	get()
protected Function<TableMetadataUnit,List<String>>	partitionKey()
org.jooq.Table<PartitionsRecord>	table()
protected List<org.jooq.Condition>	toConditions(List<String> values)	Creates JOOQ conditions based on given list of partition values.
PartitionsRecord	toRecord(TableMetadataUnit unit)	Converts Metastore component metadata unit into RDBMS table record.
TableMetadataUnit	toUnit(org.jooq.Record record)	Converts RDBMS table record into Metastore component metadata unit.

Methods inherited from class org.apache.drill.metastore.rdbms.components.tables.TablesMetadataMapper

emptyUnit, toDeleteConditions

Methods inherited from class org.apache.drill.metastore.rdbms.transform.AbstractMetadataMapper

toCondition, toFields

Methods inherited from class java.lang.Object

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

Constructor Details

PartitionMapper

public PartitionMapper()

Method Details

get

public static TablesMetadataMapper.PartitionMapper get()

table

public org.jooq.Table<PartitionsRecord> table()

Returns:

RDBMS table instance

toUnit

public TableMetadataUnit toUnit(org.jooq.Record record)

Description copied from interface: MetadataMapper

Converts RDBMS table record into Metastore component metadata unit.

Parameters:

record - RDBMS table record

Returns:

Metastore component metadata unit instance

toRecord

public PartitionsRecord toRecord(TableMetadataUnit unit)

Description copied from interface: MetadataMapper

Converts Metastore component metadata unit into RDBMS table record.

Parameters:

unit - Metastore component metadata unit

Returns:

RDBMS table record instance

fieldMapper

protected Map<MetastoreColumn,org.jooq.Field<?>> fieldMapper()

Specified by:

fieldMapper in class AbstractMetadataMapper<TableMetadataUnit,PartitionsRecord>

Returns:

mapper specific field mapper

filterVisitor

protected RdbmsFilterExpressionVisitor filterVisitor()

Specified by:

filterVisitor in class AbstractMetadataMapper<TableMetadataUnit,PartitionsRecord>

Returns:

mapper specific filter visitor

partitionKey

protected Function<TableMetadataUnit,List<String>> partitionKey()

Specified by:

partitionKey in class TablesMetadataMapper<PartitionsRecord>

Returns:

function to determine partition key for specific table

toConditions

protected List<org.jooq.Condition> toConditions(List<String> values)

Description copied from class: TablesMetadataMapper

Creates JOOQ conditions based on given list of partition values. Matching is order based.

Specified by:

toConditions in class TablesMetadataMapper<PartitionsRecord>

Parameters:

values - partition values

Returns:

list of JOOQ conditions