Package com.illumon.iris.controller.handle

Class EnterpriseWorkerHandle

java.lang.Object

com.illumon.iris.controller.handle.EnterpriseWorkerHandle

All Implemented Interfaces:

WorkerHandle

public final class EnterpriseWorkerHandle
extends Object
implements WorkerHandle

The WorkerHandle implementation for commiunicating with legacy workers.

Method Summary

Modifier and Type	Method	Description
QueryProcessorConnectionDetails	getConnectionDetails()	Get the current details for the worker connection.
QueryProcessorConnection	getProcessorConnection()
Future<PersistentQueryState>	initializeQuery()	Initialize the query after connection has been established.
void	release()	Close and release any connections to the worker.

Methods inherited from class java.lang.Object

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

Method Details

getProcessorConnection

@NotNull
public QueryProcessorConnection getProcessorConnection()

getConnectionDetails

public QueryProcessorConnectionDetails getConnectionDetails()

Description copied from interface: WorkerHandle

Get the current details for the worker connection.

Specified by:

getConnectionDetails in interface WorkerHandle

Returns:

the connection details

release

public void release()
             throws IOException

Description copied from interface: WorkerHandle

Close and release any connections to the worker.

Specified by:

release in interface WorkerHandle

Throws:

IOException - if an error occurred

initializeQuery

public Future<PersistentQueryState> initializeQuery()
                                             throws IOException

Description copied from interface: WorkerHandle

Initialize the query after connection has been established. Implementations must not block, and should return a Future from which the resulting state can be retrieved.

Specified by:

initializeQuery in interface WorkerHandle

Returns:

the state after initialization

Throws:

IOException - if a communication error occurred