Package com.illumon.iris.controller

Class PersistentQueryInfo

java.lang.Object

com.illumon.iris.controller.PersistentQueryInfo

public class PersistentQueryInfo
extends Object

Note: {PersistentQueryConfiguration, PersistentQueryState, PersistentQueryInfo, PersistentQuery, PersistentQueryClient} replace TableConfiguration.

Field Summary

Fields

Modifier and Type	Field	Description
static final io.deephaven.hash.KeyedLongObjectKey<PersistentQueryInfo>	CONFIG_SERIAL_KEY

Constructor Summary

Constructors

Constructor	Description
PersistentQueryInfo(PersistentQueryConfiguration config)

Method Summary

Modifier and Type	Method	Description
PersistentQueryConfiguration	getConfig()
PersistentQueryState	getReplicaState(int slot)
PersistentQueryState[]	getReplicaStates()
PersistentQueryState[]	getSpareStates()
PersistentQueryState	getState()	Set the designated state for client use.
boolean	isStale()
boolean	isVisibleToUser(IrisUserContext user)
boolean	isVisibleToUser(UserContext userContext, IrisGroupProvider groupProvider)
Stream<PersistentQueryState>	replicaStateStream()
void	resetNumberFailures()
void	setConfig(PersistentQueryConfiguration config)
void	setDesignatedState(PersistentQueryState state)
void	setReplicaState(PersistentQueryState state, int slot)
PersistentQueryState	updateReplicaState(PersistentQueryState state, int replicaSlot)
boolean	workerAcceptingConnections()

Methods inherited from class java.lang.Object

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

Field Details

CONFIG_SERIAL_KEY

public static final io.deephaven.hash.KeyedLongObjectKey<PersistentQueryInfo> CONFIG_SERIAL_KEY

Constructor Details

PersistentQueryInfo

public PersistentQueryInfo(@NotNull
 PersistentQueryConfiguration config)

Method Details

getConfig

@NotNull
public PersistentQueryConfiguration getConfig()

setConfig

public void setConfig(@NotNull
 PersistentQueryConfiguration config)

getState

@Nullable
public PersistentQueryState getState()

Set the designated state for client use.

Returns:

setDesignatedState

public void setDesignatedState(@NotNull
 PersistentQueryState state)

setReplicaState

public void setReplicaState(@NotNull
 PersistentQueryState state,
 int slot)

getReplicaState

@Nullable
public PersistentQueryState getReplicaState(int slot)

getReplicaStates

@NotNull
public PersistentQueryState[] getReplicaStates()

getSpareStates

@NotNull
public PersistentQueryState[] getSpareStates()

isStale

public boolean isStale()

workerAcceptingConnections

public boolean workerAcceptingConnections()

isVisibleToUser

public boolean isVisibleToUser(@NotNull
 IrisUserContext user)

isVisibleToUser

public boolean isVisibleToUser(@NotNull
 UserContext userContext,
 @NotNull
 IrisGroupProvider groupProvider)

resetNumberFailures

public void resetNumberFailures()

updateReplicaState

public PersistentQueryState updateReplicaState(PersistentQueryState state,
 int replicaSlot)

replicaStateStream

public Stream<PersistentQueryState> replicaStateStream()