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, 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)
void	handleUpdate(@NotNull TableLocationState source)
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

clearColumnLocations, deliverInitialSnapshot, getColumnLocation, 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.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, 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

makeColumnLocation

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

Specified by:

makeColumnLocation 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