Package io.deephaven.enterprise.locations.hive

Class HiveKeyFinder

java.lang.Object

io.deephaven.engine.table.impl.locations.local.KeyValuePartitionLayout<TLK,Path>

io.deephaven.engine.table.impl.locations.local.FileKeyValuePartitionLayout<EnterpriseTableLocationKey>

io.deephaven.enterprise.locations.hive.HiveKeyFinder

All Implemented Interfaces:

TableLocationKeyFinder<EnterpriseTableLocationKey>

public class HiveKeyFinder
extends FileKeyValuePartitionLayout<EnterpriseTableLocationKey>

A TableLocationKeyFinder that discovers Deephaven and parquet format tables that are laid out in Apache Hive style on disk.

Nested Class Summary

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

KeyValuePartitionLayout.LocationTableBuilder

Constructor Summary

Constructors

Constructor	Description
HiveKeyFinder(@NotNull File tableRootDirectory, @NotNull TableDefinition tableDefinition)

Method Summary

Modifier and Type	Method	Description
void	findKeys(@NotNull Consumer<EnterpriseTableLocationKey> locationKeyObserver)

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

toString

Methods inherited from class java.lang.Object

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

Constructor Details

HiveKeyFinder

public HiveKeyFinder(@NotNull
 @NotNull File tableRootDirectory,
 @NotNull
 @NotNull TableDefinition tableDefinition)

Parameters:

tableRootDirectory - The directory to traverse from

tableDefinition - the table definition

Method Details

findKeys

public void findKeys(@NotNull
 @NotNull Consumer<EnterpriseTableLocationKey> locationKeyObserver)

Specified by:

findKeys in interface TableLocationKeyFinder<EnterpriseTableLocationKey>

Overrides:

findKeys in class FileKeyValuePartitionLayout<EnterpriseTableLocationKey>