Package io.deephaven.enterprise.locations.nestedpartitioned

Class NestedPartitionedKeyFinder

java.lang.Object

io.deephaven.parquet.table.layout.DeephavenNestedPartitionLayout<NestedPartitionedUnresolvedTableLocationKey>

io.deephaven.enterprise.locations.nestedpartitioned.NestedPartitionedKeyFinder

All Implemented Interfaces:

TableLocationKeyFinder<NestedPartitionedUnresolvedTableLocationKey>

public class NestedPartitionedKeyFinder
extends DeephavenNestedPartitionLayout<NestedPartitionedUnresolvedTableLocationKey>

A TableLocationKeyFinder for locating tables stored in Legacy Deephaven Enterprise structured database. Keys are initially "unresolved" as we do not try to determine the table format (Deephaven or Parquet) at the location until it is read.

Field Summary

Fields inherited from class io.deephaven.parquet.table.layout.DeephavenNestedPartitionLayout

INTERNAL_PARTITION_KEY, PARQUET_FILE_NAME

Constructor Summary

Constructors

Constructor	Description
NestedPartitionedKeyFinder(@NotNull File tableRootDirectory, @NotNull String tableName, @NotNull String columnPartitionKey, @Nullable Predicate<String> internalPartitionValueFilter)

Method Summary

Modifier and Type	Method	Description
protected NestedPartitionedUnresolvedTableLocationKey	makeKey(@NotNull Path tableLeafDirectory, @NotNull Map<String,Comparable<?>> partitions)

Methods inherited from class io.deephaven.parquet.table.layout.DeephavenNestedPartitionLayout

findKeys, forParquet, getColumnPartitionKey, toString

Methods inherited from class java.lang.Object

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

Constructor Details

NestedPartitionedKeyFinder

public NestedPartitionedKeyFinder(@NotNull
 @NotNull File tableRootDirectory,
 @NotNull
 @NotNull String tableName,
 @NotNull
 @NotNull String columnPartitionKey,
 @Nullable
 @Nullable Predicate<String> internalPartitionValueFilter)

Parameters:

tableRootDirectory - The directory to traverse from

tableName - The table name

columnPartitionKey - The partitioning column name

internalPartitionValueFilter - Filter to control which internal partitions are included, null for all

Method Details

makeKey

protected NestedPartitionedUnresolvedTableLocationKey makeKey(@NotNull
 @NotNull Path tableLeafDirectory,
 @NotNull
 @NotNull Map<String,Comparable<?>> partitions)

Specified by:

makeKey in class DeephavenNestedPartitionLayout<NestedPartitionedUnresolvedTableLocationKey>