Class EnterprisePersistentQueryHandle
java.lang.Object
com.illumon.iris.controller.handle.PersistentQueryHandleBase
com.illumon.iris.controller.handle.EnterprisePersistentQueryHandle
- All Implemented Interfaces:
PersistentQueryHandle
A Handle to a Persistent Query backed by an Enterprise worker.
-
Field Summary
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
ConstructorsConstructorDescriptionEnterprisePersistentQueryHandle(com.fishlib.io.logger.Logger log, Object queryHandleContext) Create a new Handle for an enterprise worker. -
Method Summary
Modifier and TypeMethodDescriptionprotected WorkerHandlecreateWorkerHandle(RemoteProcessingRequest request, QueryDispatcherConnection dispatcherConnection) protected booleanonDispatcherConnected(QueryDispatcherConnection dispatcherConnection) protected voidMethods 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, warnLogMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface com.illumon.iris.controller.handle.PersistentQueryHandle
canTryToRestore, restore
-
Constructor Details
-
EnterprisePersistentQueryHandle
public EnterprisePersistentQueryHandle(@NotNull com.fishlib.io.logger.Logger log, @NotNull Object queryHandleContext) Create a new Handle for an enterprise worker.- Parameters:
log- the log.queryHandleContext- A context object containing the required parameters for this object.
-
-
Method Details
-
onStartRequested
protected void onStartRequested()- Specified by:
onStartRequestedin classPersistentQueryHandleBase
-
onDispatcherConnected
- Specified by:
onDispatcherConnectedin classPersistentQueryHandleBase
-
createWorkerHandle
protected WorkerHandle createWorkerHandle(RemoteProcessingRequest request, QueryDispatcherConnection dispatcherConnection) - Specified by:
createWorkerHandlein classPersistentQueryHandleBase
-