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
ConstructorDescriptionIcebergTableParquetLocationKey
(@NotNull URI fileUri, int order, @Nullable Map<String, Comparable<?>> partitions, @NotNull ParquetInstructions readInstructions) Construct a new IcebergTableParquetLocationKey for the suppliedfileUri
andpartitions
. -
Method Summary
Modifier and TypeMethodDescriptionGet a name for the implementing class.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 suppliedfileUri
andpartitions
.- Parameters:
fileUri
- The file that backs the keyed locationorder
- Explicit ordering index, taking precedence over other fieldspartitions
- The table partitions enclosing the table location keyed bythis
. Note that if this parameter isnull
, 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 callreadInstructions
- the instructions for customizations while reading
-
-
Method Details
-
getImplementationName
Description copied from interface:NamedImplementation
Get a name for the implementing class. Useful for abstract classes that implement
LogOutputAppendable
or overridetoString
.The default implementation is correct, but not suitable for high-frequency usage.
- Specified by:
getImplementationName
in interfaceNamedImplementation
- Overrides:
getImplementationName
in classParquetTableLocationKey
- Returns:
- A name for the implementing class
-
readInstructions
Description copied from interface:IcebergTableLocationKey
Get the read instructions for the location.- Specified by:
readInstructions
in interfaceIcebergTableLocationKey
- Returns:
- the read instructions
-