Package io.deephaven.iceberg.layout

Class IcebergKeyValuePartitionedLayout

java.lang.Object

io.deephaven.iceberg.layout.IcebergBaseLayout

io.deephaven.iceberg.layout.IcebergKeyValuePartitionedLayout

All Implemented Interfaces:

TableLocationKeyFinder<IcebergTableLocationKey>

@InternalUseOnly
public final class IcebergKeyValuePartitionedLayout
extends IcebergBaseLayout

Iceberg location finder for tables with partitions that will discover data files from a Snapshot

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	IcebergKeyValuePartitionedLayout.IdentityPartitioningColData

Field Summary

Fields inherited from class io.deephaven.iceberg.layout.IcebergBaseLayout

tableAdapter

Constructor Summary

Constructors

Constructor	Description
IcebergKeyValuePartitionedLayout(@NotNull IcebergTableAdapter tableAdapter, @NotNull ParquetInstructions parquetInstructions, @NotNull SeekableChannelsProvider seekableChannelsProvider, @Nullable org.apache.iceberg.Snapshot snapshot, @NotNull List<IcebergKeyValuePartitionedLayout.IdentityPartitioningColData> identityPartitioningColumns)	Deprecated, for removal: This API element is subject to removal in a future version.
IcebergKeyValuePartitionedLayout(@NotNull IcebergTableAdapter tableAdapter, @NotNull org.apache.iceberg.PartitionSpec partitionSpec, @NotNull IcebergReadInstructions instructions, @NotNull DataInstructionsProviderLoader dataInstructionsProvider)	Deprecated, for removal: This API element is subject to removal in a future version.

Method Summary

Modifier and Type	Method	Description
protected IcebergTableLocationKey	keyFromDataFile(@NotNull org.apache.iceberg.PartitionSpec manifestPartitionSpec, @NotNull org.apache.iceberg.ManifestFile manifestFile, @NotNull org.apache.iceberg.DataFile dataFile, @NotNull URI fileUri, @NotNull SeekableChannelsProvider channelsProvider)
String	toString()

Methods inherited from class io.deephaven.iceberg.layout.IcebergBaseLayout

computeSortedColumns, findKeys, locationKey, maybeUpdateSnapshot, updateSnapshot, updateSnapshot

Methods inherited from class java.lang.Object

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

Constructor Details

IcebergKeyValuePartitionedLayout

@Deprecated(forRemoval=true)
public IcebergKeyValuePartitionedLayout(@NotNull
 @NotNull IcebergTableAdapter tableAdapter,
 @NotNull
 @NotNull org.apache.iceberg.PartitionSpec partitionSpec,
 @NotNull
 @NotNull IcebergReadInstructions instructions,
 @NotNull
 @NotNull DataInstructionsProviderLoader dataInstructionsProvider)

Deprecated, for removal: This API element is subject to removal in a future version.

Parameters:

tableAdapter - The IcebergTableAdapter that will be used to access the table.

partitionSpec - The Iceberg partition spec for the table.

instructions - The instructions for customizations while reading.

dataInstructionsProvider - The provider for special instructions, to be used if special instructions not provided in the instructions.

IcebergKeyValuePartitionedLayout

@Deprecated(forRemoval=true)
public IcebergKeyValuePartitionedLayout(@NotNull
 @NotNull IcebergTableAdapter tableAdapter,
 @NotNull
 @NotNull ParquetInstructions parquetInstructions,
 @NotNull
 @NotNull SeekableChannelsProvider seekableChannelsProvider,
 @Nullable
 @Nullable org.apache.iceberg.Snapshot snapshot,
 @NotNull
 @NotNull List<IcebergKeyValuePartitionedLayout.IdentityPartitioningColData> identityPartitioningColumns)

Deprecated, for removal: This API element is subject to removal in a future version.

Method Details

toString

public String toString()

Overrides:

toString in class Object

keyFromDataFile

protected IcebergTableLocationKey keyFromDataFile(@NotNull
 @NotNull org.apache.iceberg.PartitionSpec manifestPartitionSpec,
 @NotNull
 @NotNull org.apache.iceberg.ManifestFile manifestFile,
 @NotNull
 @NotNull org.apache.iceberg.DataFile dataFile,
 @NotNull
 @NotNull URI fileUri,
 @NotNull
 @NotNull SeekableChannelsProvider channelsProvider)

Specified by:

keyFromDataFile in class IcebergBaseLayout