Package io.deephaven.enterprise.locations.remote

Class RemoteDeephavenTableLocation

java.lang.Object

io.deephaven.engine.table.impl.locations.impl.SubscriptionAggregator<TableLocation.Listener>

io.deephaven.engine.table.impl.locations.impl.AbstractTableLocation

io.deephaven.enterprise.locations.remote.RemoteDeephavenTableLocation

All Implemented Interfaces:

LogOutputAppendable, DelegatingLivenessReferent, LivenessReferent, ColumnToCodecMappings, TableLocation, TableLocationState, DeephavenFormatTableLocation, io.deephaven.shadow.enterprise.com.fishlib.base.log.LogOutputAppendable, io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler, NamedImplementation

public class RemoteDeephavenTableLocation
extends AbstractTableLocation
implements DeephavenFormatTableLocation, io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler, ColumnToCodecMappings

A TableLocation implementation for remote table subscriptions discovered by a io.deephaven.enterprise.tabledataservice.RemoteTableDataService.

Nested Class Summary

Nested classes/interfaces inherited from interface io.deephaven.engine.table.impl.locations.TableLocation

TableLocation.Listener

Field Summary

Fields inherited from class io.deephaven.engine.table.impl.locations.impl.SubscriptionAggregator

subscriptions

Fields inherited from interface io.deephaven.engine.table.impl.ColumnToCodecMappings

EMPTY

Fields inherited from interface io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler

NULL

Fields inherited from interface io.deephaven.engine.table.impl.locations.TableLocationState

NULL_SIZE, NULL_TIME

Constructor Summary

Constructors

Constructor	Description
RemoteDeephavenTableLocation(@NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataProtocolDriver driver, @NotNull EnterpriseTableKey tableKey, @NotNull EnterpriseTableLocationKey locationKey, @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition tableDefinition)	Create a remote table location using the specified protocol driver for acquiring table data.

Method Summary

Modifier and Type	Method	Description
protected void	activateUnderlyingDataSource()
io.deephaven.shadow.enterprise.com.fishlib.base.log.LogOutput	append(@NotNull io.deephaven.shadow.enterprise.com.fishlib.base.log.LogOutput logOutput)
protected void	deactivateUnderlyingDataSource()
String	getCodecArgs(@NotNull String columnName)
String	getCodecName(@NotNull String columnName)
@NotNull List<String[]>	getDataIndexColumns()
@NotNull List<SortColumn>	getSortedColumns()
void	handleUpdate(@NotNull TableLocationState source)
boolean	hasDataIndex(@NotNull String... columns)
@Nullable BasicDataIndex	loadDataIndex(@NotNull String... columns)
protected final @NotNull io.deephaven.enterprise.locations.remote.RemoteDeephavenColumnLocation	makeColumnLocation(@NotNull String name)
protected <T> boolean	matchSubscriptionToken(T token)
void	onComplete(@NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataRequest request)
void	onRejection(@NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataRequest request, String rejectionMessage, io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataProtocol.RequestRejectionType requestRejectionType)
void	onTableLocationKeyAdded(io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.TableLocationKey locationKey)
void	onTableLocationKeyRemoved(io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.TableLocationKey locationKey)
void	onTableLocationState(io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.TableLocationState state)
void	onTimeout(@NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataRequest request)
void	refresh()

Methods inherited from class io.deephaven.engine.table.impl.locations.impl.AbstractTableLocation

asLivenessReferent, clearColumnLocations, deliverInitialSnapshot, destroy, getColumnLocation, getDataIndex, getKey, getLastModifiedTimeMillis, getRowSet, getSize, getStateLock, getTableKey, handleUpdate, toString

Methods inherited from class io.deephaven.engine.table.impl.locations.impl.SubscriptionAggregator

activationFailed, activationSuccessful, checkHasSubscribers, postActivationHook, subscribe, supportsSubscriptions, unsubscribe

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.deephaven.engine.liveness.DelegatingLivenessReferent

dropReference, getWeakReference, tryRetainReference

Methods inherited from interface io.deephaven.engine.liveness.LivenessReferent

getReferentDescription, retainReference

Methods inherited from interface io.deephaven.util.type.NamedImplementation

getImplementationName

Methods inherited from interface io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler

checkHasSubscribers

Methods inherited from interface io.deephaven.engine.table.impl.locations.TableLocation

append, getColumnLocation, getDataIndex, getKey, getTableKey, subscribe, supportsSubscriptions, toGenericString, toStringDetailed, toStringHelper, unsubscribe

Methods inherited from interface io.deephaven.engine.table.impl.locations.TableLocationState

copyStateValuesTo, getLastModifiedTimeMillis, getRowSet, getSize, getStateLock

Constructor Details

RemoteDeephavenTableLocation

public RemoteDeephavenTableLocation(@NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataProtocolDriver driver,
 @NotNull
 @NotNull EnterpriseTableKey tableKey,
 @NotNull
 @NotNull EnterpriseTableLocationKey locationKey,
 @NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition tableDefinition)

Create a remote table location using the specified protocol driver for acquiring table data.

Parameters:

driver - the driver

tableKey - the EnterpriseTableKey identifying the table

locationKey - the EnterpriseTableLocationKey identifying the column and internal partitions

tableDefinition -

Method Details

handleUpdate

public void handleUpdate(@NotNull
 @NotNull TableLocationState source)

Overrides:

handleUpdate in class AbstractTableLocation

activateUnderlyingDataSource

protected void activateUnderlyingDataSource()

Overrides:

activateUnderlyingDataSource in class SubscriptionAggregator<TableLocation.Listener>

deactivateUnderlyingDataSource

protected void deactivateUnderlyingDataSource()

Overrides:

deactivateUnderlyingDataSource in class SubscriptionAggregator<TableLocation.Listener>

matchSubscriptionToken

protected <T> boolean matchSubscriptionToken(@NotNull
 T token)

Overrides:

matchSubscriptionToken in class SubscriptionAggregator<TableLocation.Listener>

refresh

public void refresh()

Specified by:

refresh in interface TableLocation

getSortedColumns

@NotNull
public @NotNull List<SortColumn> getSortedColumns()

Specified by:

getSortedColumns in interface TableLocation

getDataIndexColumns

@NotNull
public @NotNull List<String[]> getDataIndexColumns()

Specified by:

getDataIndexColumns in interface TableLocation

hasDataIndex

public boolean hasDataIndex(@NotNull
 @NotNull String... columns)

Specified by:

hasDataIndex in interface TableLocation

makeColumnLocation

@NotNull
protected final @NotNull io.deephaven.enterprise.locations.remote.RemoteDeephavenColumnLocation makeColumnLocation(@NotNull
 @NotNull String name)

Specified by:

makeColumnLocation in class AbstractTableLocation

loadDataIndex

@Nullable
public @Nullable BasicDataIndex loadDataIndex(@NotNull
 @NotNull String... columns)

Specified by:

loadDataIndex in class AbstractTableLocation

onTimeout

public void onTimeout(@NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataRequest request)

Specified by:

onTimeout in interface io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler

onRejection

public void onRejection(@NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataRequest request,
 String rejectionMessage,
 io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataProtocol.RequestRejectionType requestRejectionType)

Specified by:

onRejection in interface io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler

onComplete

public void onComplete(@NotNull
 @NotNull io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.TableDataRequest request)

Specified by:

onComplete in interface io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler

onTableLocationState

public void onTableLocationState(@NotNull
 io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.TableLocationState state)

Specified by:

onTableLocationState in interface io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler

onTableLocationKeyAdded

public void onTableLocationKeyAdded(@NotNull
 io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.TableLocationKey locationKey)

Specified by:

onTableLocationKeyAdded in interface io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler

onTableLocationKeyRemoved

public void onTableLocationKeyRemoved(@NotNull
 io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.TableLocationKey locationKey)

Specified by:

onTableLocationKeyRemoved in interface io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.protocol.RequestResultHandler

append

public io.deephaven.shadow.enterprise.com.fishlib.base.log.LogOutput append(@NotNull
 @NotNull io.deephaven.shadow.enterprise.com.fishlib.base.log.LogOutput logOutput)

Specified by:

append in interface DeephavenFormatTableLocation

Specified by:

append in interface io.deephaven.shadow.enterprise.com.fishlib.base.log.LogOutputAppendable

getCodecName

public String getCodecName(@NotNull
 @NotNull String columnName)

Specified by:

getCodecName in interface ColumnToCodecMappings

getCodecArgs

public String getCodecArgs(@NotNull
 @NotNull String columnName)

Specified by:

getCodecArgs in interface ColumnToCodecMappings