Package io.deephaven.enterprise.remote

Class ControllerStateWatcher.PersistentQueryStateToken

java.lang.Object

io.deephaven.enterprise.remote.ControllerStateWatcher.PersistentQueryStateToken

All Implemented Interfaces:

RemoteTableStateWatcher.StateToken

Enclosing class:

ControllerStateWatcher

public static final class ControllerStateWatcher.PersistentQueryStateToken
extends Object
implements RemoteTableStateWatcher.StateToken

A RemoteTableStateWatcher.StateToken backed by a PersistentQueryInfoMessage

Constructor Summary

Constructors

Constructor	Description
PersistentQueryStateToken(@Nullable PersistentQueryInfoMessage pqi)	Create a new ControllerStateWatcher.PersistentQueryStateToken.

Method Summary

Modifier and Type	Method	Description
@Nullable PersistentQueryInfoMessage	getQueryInfo()
boolean	isReady()	Is the upstream ready for subscriptions?
boolean	isSameTarget(@Nullable RemoteTableStateWatcher.StateToken other)	Check if this RemoteTableStateWatcher.StateToken represents the same target connection.

Methods inherited from class java.lang.Object

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

Constructor Details

PersistentQueryStateToken

public PersistentQueryStateToken(@Nullable
 @Nullable PersistentQueryInfoMessage pqi)

Create a new ControllerStateWatcher.PersistentQueryStateToken.

Parameters:

pqi - the info (or null)

Method Details

isReady

public boolean isReady()

Description copied from interface: RemoteTableStateWatcher.StateToken

Is the upstream ready for subscriptions?

Specified by:

isReady in interface RemoteTableStateWatcher.StateToken

Returns:

true if it is ready for subscriptions.

isSameTarget

public boolean isSameTarget(@Nullable
 @Nullable RemoteTableStateWatcher.StateToken other)

Description copied from interface: RemoteTableStateWatcher.StateToken

Check if this RemoteTableStateWatcher.StateToken represents the same target connection. This is useful, for example, if a PQ Spare replaces a worker.

Specified by:

isSameTarget in interface RemoteTableStateWatcher.StateToken

Parameters:

other - the RemoteTableStateWatcher.StateToken to compare with

Returns:

true if the other token represents the same target

getQueryInfo

@Nullable
public @Nullable PersistentQueryInfoMessage getQueryInfo()