Package io.deephaven.enterprise.compatibility.locationprovider

Class CoreFromEnterpriseTableLocationProvider

java.lang.Object

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

io.deephaven.engine.table.impl.locations.impl.AbstractTableLocationProvider

io.deephaven.enterprise.compatibility.locationprovider.CoreFromEnterpriseTableLocationProvider

All Implemented Interfaces:

TableLocationProvider, NamedImplementation

public class CoreFromEnterpriseTableLocationProvider
extends AbstractTableLocationProvider

This class adapts a Legacy Enterprise TableLocationProvider into a Core TableLocationProvider.

In general, we create Core TableLocationProviders; but there are some circumstances where an Enterprise TableLocationProvider is needed and we must adapt it to the Core engine. In particular, this is used to implement a last-by DIS. The DataImportServer provides a TableLocationProvider (and we need that specific one for consistency), but we want to export our resultant tables over Barrage.

Nested Class Summary

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

TableLocationProvider.Listener

Field Summary

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

subscriptions

Constructor Summary

Constructors

Constructor	Description
CoreFromEnterpriseTableLocationProvider(io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.TableLocationProvider enterpriseTableLocationProvider, String partitionColumnName, io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition enterpriseDefinition)	Create a Core TableLocationProvider that wraps the given Enterprise TableLocationProvider.

Method Summary

Modifier and Type	Method	Description
protected void	activateUnderlyingDataSource()
protected void	deactivateUnderlyingDataSource()
protected @NotNull TableLocation	makeTableLocation(@NotNull TableLocationKey locationKey)
protected <T> boolean	matchSubscriptionToken(T token)
void	refresh()

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

beginTransaction, deliverInitialSnapshot, doInitialization, endTransaction, ensureInitialized, getKey, getLocationUpdateMode, getTableLocationIfPresent, getTableLocationKeys, getUpdateMode, handleTableLocationKeyAdded, handleTableLocationKeyAdded, handleTableLocationKeyRemoved, hasTableLocationKey, isInitialized, removeTableLocationKey, setInitialized, toString, visitLocationKey

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.engine.table.impl.locations.TableLocationProvider

getName, getTableLocation, getTableLocationKeys, getTableLocationKeys, subscribe, supportsSubscriptions, unsubscribe

Constructor Details

CoreFromEnterpriseTableLocationProvider

public CoreFromEnterpriseTableLocationProvider(io.deephaven.shadow.enterprise.com.illumon.iris.db.v2.locations.TableLocationProvider enterpriseTableLocationProvider,
 String partitionColumnName,
 io.deephaven.shadow.enterprise.com.illumon.iris.db.tables.TableDefinition enterpriseDefinition)

Create a Core TableLocationProvider that wraps the given Enterprise TableLocationProvider.

Parameters:

enterpriseTableLocationProvider - the Enterprise TableLocationProvider

partitionColumnName - the name of the column partition for this Table

enterpriseDefinition -

Method Details

makeTableLocation

@NotNull
protected @NotNull TableLocation makeTableLocation(@NotNull
 @NotNull TableLocationKey locationKey)

Specified by:

makeTableLocation in class AbstractTableLocationProvider

refresh

public void refresh()

activateUnderlyingDataSource

protected void activateUnderlyingDataSource()

Overrides:

activateUnderlyingDataSource in class SubscriptionAggregator<TableLocationProvider.Listener>

deactivateUnderlyingDataSource

protected void deactivateUnderlyingDataSource()

Overrides:

deactivateUnderlyingDataSource in class SubscriptionAggregator<TableLocationProvider.Listener>

matchSubscriptionToken

protected <T> boolean matchSubscriptionToken(T token)

Overrides:

matchSubscriptionToken in class SubscriptionAggregator<TableLocationProvider.Listener>