Package io.deephaven.enterprise.iceberg.discovery

Class DiscoveryResultImpl

java.lang.Object

io.deephaven.enterprise.iceberg.discovery.DiscoveryResultImpl

All Implemented Interfaces:

DiscoveryResult

@InternalUseOnly
public final class DiscoveryResultImpl
extends Object
implements DiscoveryResult

The implementation of a DiscoveryResult

Constructor Summary

Constructors

Constructor	Description
DiscoveryResultImpl(@NotNull DiscoveryConfig config, @NotNull IcebergTableAdapter tableAdapter, @NotNull IcebergReadInstructions readInstructions, @NotNull String namespace, @NotNull String tableName, DataInstructionsProviderLoader dataInstructionsProvider, org.apache.iceberg.catalog.TableIdentifier tableId)	Create a DiscoveryResultImpl

Method Summary

Modifier and Type	Method	Description
@NotNull DiscoveryConfig	getConfig()	Get the DiscoveryConfig used for the discovery.
DataInstructionsProviderLoader	getDataInstructionsProvider()	Get the DataInstructionsProviderLoader for use with Iceberg locations.
@NotNull IcebergTableAdapter	getIcebergTableAdapter()	Get the discovered IcebergTableAdapter.
@NotNull String	getNamespace()	Get the namespace of the table.
@NotNull IcebergReadInstructions	getReadInstructions()	Get the completed IcebergReadInstructions that can be used to fetch Deephaven Tables.
org.apache.iceberg.catalog.TableIdentifier	getTableIdentifier()	Get the TableIdentifier used to discover the table.
@NotNull String	getTableName()	Get the name of the table.

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.enterprise.iceberg.discovery.DiscoveryResult

deployWithEmbeddedEndpoint, deployWithEndpointReference

Constructor Details

DiscoveryResultImpl

public DiscoveryResultImpl(@NotNull
 @NotNull DiscoveryConfig config,
 @NotNull
 @NotNull IcebergTableAdapter tableAdapter,
 @NotNull
 @NotNull IcebergReadInstructions readInstructions,
 @NotNull
 @NotNull String namespace,
 @NotNull
 @NotNull String tableName,
 DataInstructionsProviderLoader dataInstructionsProvider,
 org.apache.iceberg.catalog.TableIdentifier tableId)

Create a DiscoveryResultImpl

Parameters:

config - the config

namespace - the resolved namespace

tableName - the resolved table name

dataInstructionsProvider -

Method Details

getConfig

@NotNull
public @NotNull DiscoveryConfig getConfig()

Description copied from interface: DiscoveryResult

Get the DiscoveryConfig used for the discovery.

Specified by:

getConfig in interface DiscoveryResult

Returns:

the configuration.

getNamespace

@NotNull
public @NotNull String getNamespace()

Description copied from interface: DiscoveryResult

Get the namespace of the table. If DiscoveryConfig.namespace() was not provided, then it is derived from the Iceberg Table Identifier

Specified by:

getNamespace in interface DiscoveryResult

Returns:

the namespace of the table.

getTableName

@NotNull
public @NotNull String getTableName()

Description copied from interface: DiscoveryResult

Get the name of the table. If DiscoveryConfig.tableName() was not provided, then it is derived from the Iceberg Table Identifier.

Specified by:

getTableName in interface DiscoveryResult

Returns:

the table name.

getIcebergTableAdapter

@NotNull
public @NotNull IcebergTableAdapter getIcebergTableAdapter()

Description copied from interface: DiscoveryResult

Get the discovered IcebergTableAdapter.

Specified by:

getIcebergTableAdapter in interface DiscoveryResult

Returns:

the Iceberg IcebergTableAdapter

getReadInstructions

@NotNull
public @NotNull IcebergReadInstructions getReadInstructions()

Description copied from interface: DiscoveryResult

Get the completed IcebergReadInstructions that can be used to fetch Deephaven Tables.

Specified by:

getReadInstructions in interface DiscoveryResult

Returns:

the IcebergReadInstructions

getDataInstructionsProvider

public DataInstructionsProviderLoader getDataInstructionsProvider()

Description copied from interface: DiscoveryResult

Get the DataInstructionsProviderLoader for use with Iceberg locations.

Specified by:

getDataInstructionsProvider in interface DiscoveryResult

Returns:

the DataInstructionsProviderLoader

getTableIdentifier

public org.apache.iceberg.catalog.TableIdentifier getTableIdentifier()

Description copied from interface: DiscoveryResult

Get the TableIdentifier used to discover the table.

Specified by:

getTableIdentifier in interface DiscoveryResult

Returns:

the TableIdentifier