Package io.deephaven.iceberg.location

Class IcebergTableParquetLocationKey

java.lang.Object

io.deephaven.engine.table.impl.locations.impl.PartitionedTableLocationKey

io.deephaven.engine.table.impl.locations.local.URITableLocationKey

io.deephaven.parquet.table.location.ParquetTableLocationKey

io.deephaven.iceberg.location.IcebergTableParquetLocationKey

All Implemented Interfaces:

LogOutputAppendable, ImmutableTableLocationKey, TableLocationKey, IcebergTableLocationKey, NamedImplementation, Comparable<TableLocationKey>

public class IcebergTableParquetLocationKey
extends ParquetTableLocationKey
implements IcebergTableLocationKey

TableLocationKey implementation for use with data stored in Iceberg tables in the parquet format.

Nested Class Summary

Nested classes/interfaces inherited from class io.deephaven.engine.table.impl.locations.impl.PartitionedTableLocationKey

PartitionedTableLocationKey.PartitionsComparator, PartitionedTableLocationKey.PartitionsFormatter

Field Summary

Fields inherited from class io.deephaven.engine.table.impl.locations.local.URITableLocationKey

uri

Fields inherited from class io.deephaven.engine.table.impl.locations.impl.PartitionedTableLocationKey

partitions

Fields inherited from interface io.deephaven.engine.table.impl.locations.ImmutableTableLocationKey

ZERO_LENGTH_IMMUTABLE_TABLE_LOCATION_KEY_ARRAY

Constructor Summary

Constructors

Constructor	Description
IcebergTableParquetLocationKey(@NotNull URI fileUri, int order, @Nullable Map<String,Comparable<?>> partitions, @NotNull ParquetInstructions readInstructions)	Construct a new IcebergTableParquetLocationKey for the supplied fileUri and partitions.

Method Summary

Modifier and Type	Method	Description
String	getImplementationName()	Get a name for the implementing class.
ParquetInstructions	readInstructions()	Get the read instructions for the location.

Methods inherited from class io.deephaven.parquet.table.location.ParquetTableLocationKey

getFileReader, getMetadata, getRowGroupIndices, setFileReader, setMetadata, setRowGroupIndices

Methods inherited from class io.deephaven.engine.table.impl.locations.local.URITableLocationKey

append, compareTo, equals, getURI, hashCode, toString

Methods inherited from class io.deephaven.engine.table.impl.locations.impl.PartitionedTableLocationKey

getPartitionKeys, getPartitionValue

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Comparable

compareTo

Methods inherited from interface io.deephaven.engine.table.impl.locations.ImmutableTableLocationKey

makeImmutable

Methods inherited from interface io.deephaven.base.log.LogOutputAppendable

append

Methods inherited from interface io.deephaven.engine.table.impl.locations.TableLocationKey

getPartitionKeys, getPartitionValue

Constructor Details

IcebergTableParquetLocationKey

public IcebergTableParquetLocationKey(@NotNull
 @NotNull URI fileUri,
 int order,
 @Nullable
 @Nullable Map<String,Comparable<?>> partitions,
 @NotNull
 @NotNull ParquetInstructions readInstructions)

Construct a new IcebergTableParquetLocationKey for the supplied fileUri and partitions.

Parameters:

fileUri - The file that backs the keyed location

order - Explicit ordering index, taking precedence over other fields

partitions - The table partitions enclosing the table location keyed by this. Note that if this parameter is null, the location will be a member of no partitions. An ordered copy of the map will be made, so the calling code is free to mutate the map after this call

readInstructions - the instructions for customizations while reading

Method Details

getImplementationName

public String getImplementationName()

Description copied from interface: NamedImplementation

Get a name for the implementing class. Useful for abstract classes that implement LogOutputAppendable or override toString.

The default implementation is correct, but not suitable for high-frequency usage.

Specified by:

getImplementationName in interface NamedImplementation

Overrides:

getImplementationName in class ParquetTableLocationKey

Returns:

A name for the implementing class

readInstructions

public ParquetInstructions readInstructions()

Description copied from interface: IcebergTableLocationKey

Get the read instructions for the location.

Specified by:

readInstructions in interface IcebergTableLocationKey

Returns:

the read instructions