Package io.deephaven.enterprise.locations.local

Class EnterpriseFixedPartitionedKeyFinder

java.lang.Object

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

io.deephaven.enterprise.locations.local.EnterpriseFixedPartitionedKeyFinder

All Implemented Interfaces:

TableLocationKeyFinder<EnterpriseTableLocationKeyUnresolved>

public class EnterpriseFixedPartitionedKeyFinder
extends DeephavenNestedPartitionLayout<EnterpriseTableLocationKeyUnresolved>

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
EnterpriseFixedPartitionedKeyFinder(@NotNull File tableRootDirectory, @NotNull String tableName, @NotNull String columnPartitionKey, @Nullable Predicate<String> internalPartitionValueFilter)

Method Summary

Modifier and Type	Method	Description
protected EnterpriseTableLocationKeyUnresolved	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

EnterpriseFixedPartitionedKeyFinder

public EnterpriseFixedPartitionedKeyFinder(@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 EnterpriseTableLocationKeyUnresolved makeKey(@NotNull
 @NotNull Path tableLeafDirectory,
 @NotNull
 @NotNull Map<String,Comparable<?>> partitions)

Specified by:

makeKey in class DeephavenNestedPartitionLayout<EnterpriseTableLocationKeyUnresolved>