Package io.deephaven.enterprise.webclientdata2

Class PersistentQueryTablesContext

java.lang.Object

io.deephaven.util.referencecounting.ReferenceCounted

io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

io.deephaven.engine.liveness.ReferenceCountedLivenessNode

io.deephaven.enterprise.webclientdata2.PersistentQueryTablesContext

All Implemented Interfaces:

LogOutputAppendable, LivenessManager, LivenessNode, LivenessReferent

public class PersistentQueryTablesContext
extends ReferenceCountedLivenessNode

Creates and makes available tables associated to controller subscriptions for PQ state changes. The object is a liveness node managed by the tables it creates, to ensure their liveness.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	GEN_COL_NAME
static final String	MULTIPLE_STATES_COLUMN_NAME
static final String	REPLICA_SLOT_COLUMN_NAME
static final String	SERIAL_COLUMN_NAME
static final String	SPARE_COUNT_COLUMN_NAME

Constructor Summary

Constructors

Constructor	Description
PersistentQueryTablesContext(String user, PersistentQueryControllerClient controllerClient, GroupProvider groupProvider, UpdateSourceRegistrar updateSourceRegistrar, Runnable shutdownHook)	Create a new object of this class

Method Summary

Modifier and Type	Method	Description
static String	configTypeNameToDisplayableName(String configTypeName)
void	destroy()
Table	getQueryInfoTable()	Get the QueryInfo table
Table	getRawConfigTable()	Get the raw Config table
Table	getRawStateTable()	Get the raw State table
static @Nullable String	getSchedulingDetails(String[] scheduling)
Table	getScopeNamesAndTypeTable()	Get the ScopeNamesAndType table
void	shutdown()	Ask this object to shutdown itself.
static String	statusAsString(Object enumName)
void	waitUntilInitialSubscriptionDone()	Block until the initial controller client subscription is completed.

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessNode

getWeakReference, initializeTransientFieldsForLiveness, onReferenceCountAtZero, tryManage, tryUnmanage, tryUnmanage

Methods inherited from class io.deephaven.engine.liveness.ReferenceCountedLivenessReferent

dropReference, tryRetainReference

Methods inherited from class io.deephaven.util.referencecounting.ReferenceCounted

append, decrementReferenceCount, forceReferenceCountToZero, getReferenceCountDebug, incrementReferenceCount, resetReferenceCount, toString, tryDecrementReferenceCount, tryIncrementReferenceCount

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.LivenessManager

manage, unmanage, unmanage

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

dropReference, getReferentDescription, retainReference, tryRetainReference

Field Details

SERIAL_COLUMN_NAME

public static final String SERIAL_COLUMN_NAME

See Also:

• Constant Field Values

SPARE_COUNT_COLUMN_NAME

public static final String SPARE_COUNT_COLUMN_NAME

See Also:

• Constant Field Values

MULTIPLE_STATES_COLUMN_NAME

public static final String MULTIPLE_STATES_COLUMN_NAME

See Also:

• Constant Field Values

REPLICA_SLOT_COLUMN_NAME

public static final String REPLICA_SLOT_COLUMN_NAME

See Also:

• Constant Field Values

GEN_COL_NAME

public static final String GEN_COL_NAME

See Also:

• Constant Field Values

Constructor Details

PersistentQueryTablesContext

public PersistentQueryTablesContext(String user,
 PersistentQueryControllerClient controllerClient,
 GroupProvider groupProvider,
 UpdateSourceRegistrar updateSourceRegistrar,
 Runnable shutdownHook)

Create a new object of this class

Parameters:

controllerClient - a controller client where to add an observer

updateSourceRegistrar - the registrar to use for this object

shutdownHook - code to run when this object is destroyed

Method Details

getRawConfigTable

public Table getRawConfigTable()

Get the raw Config table

Returns:

a table

getRawStateTable

public Table getRawStateTable()

Get the raw State table

Returns:

a table

waitUntilInitialSubscriptionDone

public void waitUntilInitialSubscriptionDone()

Block until the initial controller client subscription is completed.

getQueryInfoTable

public Table getQueryInfoTable()

Get the QueryInfo table

Returns:

a table

getScopeNamesAndTypeTable

public Table getScopeNamesAndTypeTable()

Get the ScopeNamesAndType table

Returns:

a table

shutdown

public void shutdown()

Ask this object to shutdown itself.

destroy

public void destroy()

Overrides:

destroy in class ReferenceCountedLivenessReferent

statusAsString

@ScriptApi
public static String statusAsString(Object enumName)

configTypeNameToDisplayableName

@ScriptApi
public static String configTypeNameToDisplayableName(String configTypeName)

getSchedulingDetails

@ScriptApi
@Nullable
public static @Nullable String getSchedulingDetails(String[] scheduling)