| Modifier and Type | Method and Description |
|---|---|
static TableMetadataUnit |
TestData.basicTableMetadataUnit()
Returns table metadata unit where all fields are filled in.
|
| Modifier and Type | Field and Description |
|---|---|
static TableMetadataUnit |
TableMetadataUnit.EMPTY_UNIT |
protected static TableMetadataUnit |
AbstractBasicTablesRequestsTest.nationTable |
| Modifier and Type | Method and Description |
|---|---|
TableMetadataUnit |
TableMetadataUnit.Builder.build() |
TableMetadataUnit |
BasicTablesRequests.interestingColumnsAndPartitionKeys(TableInfo tableInfo)
Returns tables interesting columns and partition keys based on given table information.
|
| Modifier and Type | Method and Description |
|---|---|
List<TableMetadataUnit> |
BasicTablesRequests.metadata(TableInfo tableInfo,
Collection<MetadataInfo> metadataInfos)
Returns list of
TableMetadataUnit metadata based on the given table information, and metadata identifiers. |
List<TableMetadataUnit> |
BasicTablesRequests.request(BasicTablesRequests.RequestMetadata requestMetadata)
Executes Metastore Tables read request based on given information in
BasicTablesRequests.RequestMetadata. |
| Modifier and Type | Method and Description |
|---|---|
static MetastoreTableInfo |
MetastoreTableInfo.of(TableInfo tableInfo,
TableMetadataUnit unit,
long metastoreVersion) |
| Modifier and Type | Method and Description |
|---|---|
static BasicTablesTransformer.MetadataHolder |
BasicTablesTransformer.all(List<TableMetadataUnit> units) |
static List<FileMetadata> |
BasicTablesTransformer.files(List<TableMetadataUnit> units) |
static List<PartitionMetadata> |
BasicTablesTransformer.partitions(List<TableMetadataUnit> units) |
static List<RowGroupMetadata> |
BasicTablesTransformer.rowGroups(List<TableMetadataUnit> units) |
static List<SegmentMetadata> |
BasicTablesTransformer.segments(List<TableMetadataUnit> units) |
static List<BaseTableMetadata> |
BasicTablesTransformer.tables(List<TableMetadataUnit> units) |
| Modifier and Type | Method and Description |
|---|---|
IcebergMetastoreContext<TableMetadataUnit> |
IcebergTables.context() |
List<TableMetadataUnit> |
TablesOutputDataTransformer.execute() |
InputDataTransformer<TableMetadataUnit> |
TablesTransformer.inputData() |
Modify<TableMetadataUnit> |
IcebergTables.modify() |
OperationTransformer<TableMetadataUnit> |
TablesTransformer.operation() |
OutputDataTransformer<TableMetadataUnit> |
TablesTransformer.outputData() |
Read<TableMetadataUnit> |
IcebergTables.read() |
Transformer<TableMetadataUnit> |
IcebergTables.transformer() |
| Modifier and Type | Method and Description |
|---|---|
static TableKey |
TableKey.of(TableMetadataUnit unit) |
| Modifier and Type | Method and Description |
|---|---|
List<Overwrite> |
TablesOperationTransformer.toOverwrite(List<TableMetadataUnit> units)
Groups given list of
TableMetadataUnit based on table key
(storage plugin, workspace and table name), each table key is grouped by metadata key. |
| Constructor and Description |
|---|
TablesOperationTransformer(IcebergMetastoreContext<TableMetadataUnit> context) |
TablesTransformer(IcebergMetastoreContext<TableMetadataUnit> context) |
| Modifier and Type | Method and Description |
|---|---|
TableMetadataUnit |
BaseMetadata.toMetadataUnit() |
TableMetadataUnit |
NonInterestingColumnsMetadata.toMetadataUnit() |
TableMetadataUnit |
Metadata.toMetadataUnit()
Converts
Metadata implementation into TableMetadataUnit instance
which will be used to write data into Drill Metastore Tables. |
| Modifier and Type | Field and Description |
|---|---|
protected static Function<TableMetadataUnit,List<String>> |
TablesMetadataMapper.COMPONENT_PARTITION_KEY |
protected static Function<TableMetadataUnit,List<String>> |
TablesMetadataMapper.TABLE_PARTITION_KEY |
| Modifier and Type | Method and Description |
|---|---|
TableMetadataUnit |
TablesMetadataMapper.emptyUnit() |
TableMetadataUnit |
TablesMetadataMapper.TableMapper.toUnit(org.jooq.Record record) |
TableMetadataUnit |
TablesMetadataMapper.SegmentMapper.toUnit(org.jooq.Record record) |
TableMetadataUnit |
TablesMetadataMapper.FileMapper.toUnit(org.jooq.Record record) |
TableMetadataUnit |
TablesMetadataMapper.RowGroupMapper.toUnit(org.jooq.Record record) |
TableMetadataUnit |
TablesMetadataMapper.PartitionMapper.toUnit(org.jooq.Record record) |
| Modifier and Type | Method and Description |
|---|---|
RdbmsMetastoreContext<TableMetadataUnit> |
RdbmsTables.context() |
Modify<TableMetadataUnit> |
RdbmsTables.modify() |
protected abstract Function<TableMetadataUnit,List<String>> |
TablesMetadataMapper.partitionKey() |
protected Function<TableMetadataUnit,List<String>> |
TablesMetadataMapper.TableMapper.partitionKey() |
protected Function<TableMetadataUnit,List<String>> |
TablesMetadataMapper.SegmentMapper.partitionKey() |
protected Function<TableMetadataUnit,List<String>> |
TablesMetadataMapper.FileMapper.partitionKey() |
protected Function<TableMetadataUnit,List<String>> |
TablesMetadataMapper.RowGroupMapper.partitionKey() |
protected Function<TableMetadataUnit,List<String>> |
TablesMetadataMapper.PartitionMapper.partitionKey() |
Read<TableMetadataUnit> |
RdbmsTables.read() |
MetadataMapper<TableMetadataUnit,? extends org.jooq.Record> |
TablesTransformer.toMapper(MetadataType metadataType) |
Set<MetadataMapper<TableMetadataUnit,? extends org.jooq.Record>> |
TablesTransformer.toMappers(Set<MetadataType> metadataTypes) |
Transformer<TableMetadataUnit> |
RdbmsTables.transformer() |
| Modifier and Type | Method and Description |
|---|---|
org.jooq.generated.tables.records.TablesRecord |
TablesMetadataMapper.TableMapper.toRecord(TableMetadataUnit unit) |
org.jooq.generated.tables.records.SegmentsRecord |
TablesMetadataMapper.SegmentMapper.toRecord(TableMetadataUnit unit) |
org.jooq.generated.tables.records.FilesRecord |
TablesMetadataMapper.FileMapper.toRecord(TableMetadataUnit unit) |
org.jooq.generated.tables.records.RowGroupsRecord |
TablesMetadataMapper.RowGroupMapper.toRecord(TableMetadataUnit unit) |
org.jooq.generated.tables.records.PartitionsRecord |
TablesMetadataMapper.PartitionMapper.toRecord(TableMetadataUnit unit) |
| Modifier and Type | Method and Description |
|---|---|
List<org.jooq.Condition> |
TablesMetadataMapper.toDeleteConditions(List<TableMetadataUnit> units) |
List<RdbmsOperation.Overwrite> |
TablesTransformer.toOverwrite(List<TableMetadataUnit> units) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.