Package com.illumon.iris.controller.handle

Class CommunityPersistentQueryHandle

java.lang.Object

com.illumon.iris.controller.handle.PersistentQueryHandleBase

com.illumon.iris.controller.handle.CommunityPersistentQueryHandle

All Implemented Interfaces:

PersistentQueryHandle

public class CommunityPersistentQueryHandle
extends PersistentQueryHandleBase

A Handle to a Persistent Query backed by a Core+ worker.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	CommunityPersistentQueryHandle.CommunityWorkerHandle

Field Summary

Fields

Modifier and Type	Field	Description
static final int	MAX_INBOUND_MESSAGE_SIZE

Fields inherited from class com.illumon.iris.controller.handle.PersistentQueryHandleBase

config, configurationType, dispatcherConnectionHandler, encryption, executorService, groupProvider, loader, log, logPrefix, state, stateLock, workerProcessInfoId, workerRequestHandle

Constructor Summary

Constructors

Constructor	Description
CommunityPersistentQueryHandle(com.fishlib.io.logger.Logger log, Object queryHandleContext)	Create a new Handle for an enterprise worker.

Method Summary

Modifier and Type	Method	Description
boolean	canTryToRestore()	Check whether the class of this object can attempt to restore already running workers.
protected WorkerHandle	createWorkerHandle(RemoteProcessingRequest request, QueryDispatcherConnection dispatcherConnection)
protected boolean	onDispatcherConnected(QueryDispatcherConnection dispatcherConnection)
protected void	onStartRequested()
boolean	restore(PersistentQueryState oldState, long deadlineMillis)	Recreate a worker handle for an existing worker.
static void	shutdownExecutors()

Methods inherited from class com.illumon.iris.controller.handle.PersistentQueryHandleBase

checkQueryTerminatingOrTerminal, ensureShutdown, errorLog, getScriptCode, getState, getStateLock, getVersion, getWorkerHandle, infoLog, maybeSetTerminalStatus, onError, onFailure, onFailure, publishState, restore, setReplicaSlot, shutdown, start, warnLog

Methods inherited from class java.lang.Object

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

Field Details

MAX_INBOUND_MESSAGE_SIZE

public static final int MAX_INBOUND_MESSAGE_SIZE

Constructor Details

CommunityPersistentQueryHandle

public CommunityPersistentQueryHandle(@NotNull
 com.fishlib.io.logger.Logger log,
 @NotNull
 Object queryHandleContext)

Create a new Handle for an enterprise worker. After creating a handle, either start() should be called, in the case of a new worker, or restore() should be called, in the case of a pre-existing worker orphan that is being re-parented.

Parameters:

log - the log.

queryHandleContext - A context object containing the required parameters for this object.

Method Details

shutdownExecutors

public static void shutdownExecutors()

onStartRequested

protected void onStartRequested()

Specified by:

onStartRequested in class PersistentQueryHandleBase

onDispatcherConnected

protected boolean onDispatcherConnected(@NotNull
 QueryDispatcherConnection dispatcherConnection)

Specified by:

onDispatcherConnected in class PersistentQueryHandleBase

canTryToRestore

public boolean canTryToRestore()

Description copied from interface: PersistentQueryHandle

Check whether the class of this object can attempt to restore already running workers.

Returns:

true if the class of this object can attempt to restore an already running worker

restore

public boolean restore(@NotNull
 PersistentQueryState oldState,
 long deadlineMillis)

Recreate a worker handle for an existing worker.

Parameters:

oldState - the state of the existing worker

deadlineMillis - when (in millis since the epoch) the worker must be restored by, or we should give up

Returns:

true if the worker handle was restored successfully, false otherwise.

createWorkerHandle

protected WorkerHandle createWorkerHandle(RemoteProcessingRequest request,
 QueryDispatcherConnection dispatcherConnection)

Specified by:

createWorkerHandle in class PersistentQueryHandleBase