Package io.deephaven.iceberg.layout

Class IcebergBaseLayout

java.lang.Object

io.deephaven.iceberg.layout.IcebergBaseLayout

All Implemented Interfaces:

TableLocationKeyFinder<IcebergTableLocationKey>

Direct Known Subclasses:

IcebergFlatLayout, IcebergKeyValuePartitionedLayout

public abstract class IcebergBaseLayout
extends Object
implements TableLocationKeyFinder<IcebergTableLocationKey>

Constructor Summary

Constructors

Constructor	Description
IcebergBaseLayout(@NotNull TableDefinition tableDef, @NotNull org.apache.iceberg.Table table, @NotNull org.apache.iceberg.Snapshot tableSnapshot, @NotNull org.apache.iceberg.io.FileIO fileIO, @NotNull IcebergInstructions instructions)

Method Summary

Modifier and Type	Method	Description
void	findKeys(@NotNull Consumer<IcebergTableLocationKey> locationKeyObserver)	Find keys and deliver them to the locationKeyObserver.
protected IcebergTableLocationKey	locationKey(org.apache.iceberg.FileFormat format, URI fileUri, @Nullable Map<String,Comparable<?>> partitions)

Methods inherited from class java.lang.Object

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

Constructor Details

IcebergBaseLayout

public IcebergBaseLayout(@NotNull
 @NotNull TableDefinition tableDef,
 @NotNull
 @NotNull org.apache.iceberg.Table table,
 @NotNull
 @NotNull org.apache.iceberg.Snapshot tableSnapshot,
 @NotNull
 @NotNull org.apache.iceberg.io.FileIO fileIO,
 @NotNull
 @NotNull IcebergInstructions instructions)

Parameters:

tableDef - The TableDefinition that will be used for the table.

table - The Table to discover locations for.

tableSnapshot - The Snapshot from which to discover data files.

fileIO - The file IO to use for reading manifest data files.

instructions - The instructions for customizations while reading.

Method Details

locationKey

protected IcebergTableLocationKey locationKey(org.apache.iceberg.FileFormat format,
 URI fileUri,
 @Nullable
 @Nullable Map<String,Comparable<?>> partitions)

findKeys

public void findKeys(@NotNull
 @NotNull Consumer<IcebergTableLocationKey> locationKeyObserver)

Description copied from interface: TableLocationKeyFinder

Find keys and deliver them to the locationKeyObserver.

Specified by:

findKeys in interface TableLocationKeyFinder<IcebergTableLocationKey>

Parameters:

locationKeyObserver - Per-key callback