Package com.illumon.iris.db.tables.remotequery

Interface QueryDispatcherConnection

All Known Implementing Classes:

QueryDispatcherConnectionImpl

public interface QueryDispatcherConnection

A connection to a remote query dispatcher.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	QueryDispatcherConnection.QueryProcessorRequestHandle	Single-use query processor request tracking mechanism.

Method Summary

Modifier and Type	Method	Description
String	getDispatcherHost()
QueryProcessorConnection	getQueryProcessor(boolean addClientClassesToClassPath, List<RemoteQueryClassDefinition> classList, long timeoutMillis)
QueryProcessorConnection	getQueryProcessor(QueryDispatcherConnection.QueryProcessorRequestHandle handle, RemoteProcessingRequest request, boolean exportQueryScope, List<RemoteQueryClassDefinition> classList, long timeoutMillis, QueryProcessorConnection.DisconnectHandler disconnectHandler, com.fishlib.net.ConnectionMonitor.Params connectionMonitorParams)
QueryProcessorConnection	getQueryProcessor(QueryDispatcherConnection.QueryProcessorRequestHandle handle, RemoteProcessingRequest request, boolean exportQueryScope, List<RemoteQueryClassDefinition> classList, long timeoutMillis, QueryProcessorConnection.DisconnectHandler disconnectHandler, com.fishlib.net.ConnectionMonitor.Params connectionMonitorParams, com.fishlib.auth.WAuthenticationClientManager authenticationClientManager)
QueryProcessorConnection	getQueryProcessor(RemoteProcessingRequest request, List<RemoteQueryClassDefinition> classList)
QueryProcessorConnection	getQueryProcessor(RemoteProcessingRequest request, List<RemoteQueryClassDefinition> classList, long timeoutMillis)
default QueryDispatcherConnection.QueryProcessorRequestHandle	getQueryProcessorRequestHandle()	Delegate to getQueryProcessorRequestHandle(boolean) with combineWorkerConnectionStats=false to create a, single-use handle for use in requesting a new query processor.
QueryDispatcherConnection.QueryProcessorRequestHandle	getQueryProcessorRequestHandle(boolean combineWorkerConnectionStats)	Create a new, single-use handle for use in requesting a new query processor.
boolean	isConnected()
void	pushClientClasses(List<RemoteQueryClassDefinition> classList)
void	release(boolean force)
com.fishlib.base.Command	sendCommand(com.fishlib.base.Command command)

Method Details

getDispatcherHost

String getDispatcherHost()

pushClientClasses

void pushClientClasses(List<RemoteQueryClassDefinition> classList) throws IOException

Throws:

IOException

sendCommand

com.fishlib.base.Command sendCommand(com.fishlib.base.Command command) throws IOException

Throws:

IOException

getQueryProcessorRequestHandle

default QueryDispatcherConnection.QueryProcessorRequestHandle getQueryProcessorRequestHandle()

Delegate to getQueryProcessorRequestHandle(boolean) with combineWorkerConnectionStats=false to create a, single-use handle for use in requesting a new query processor.

Returns:

A new, single-use handle for use in requesting a new query processor.

getQueryProcessorRequestHandle

QueryDispatcherConnection.QueryProcessorRequestHandle getQueryProcessorRequestHandle(boolean combineWorkerConnectionStats)

Create a new, single-use handle for use in requesting a new query processor.

Parameters:

combineWorkerConnectionStats - if true, use one set of statistics items for the worker connection statistics, rather than a different set of items for each worker connection

Returns:

A new, single-use handle for use in requesting a new query processor.

getQueryProcessor

QueryProcessorConnection getQueryProcessor(QueryDispatcherConnection.QueryProcessorRequestHandle handle, RemoteProcessingRequest request, boolean exportQueryScope, List<RemoteQueryClassDefinition> classList, long timeoutMillis, @Nullable QueryProcessorConnection.DisconnectHandler disconnectHandler, @Nullable com.fishlib.net.ConnectionMonitor.Params connectionMonitorParams, @NotNull com.fishlib.auth.WAuthenticationClientManager authenticationClientManager) throws RemoteQueryException

Throws:

RemoteQueryException

getQueryProcessor

QueryProcessorConnection getQueryProcessor(QueryDispatcherConnection.QueryProcessorRequestHandle handle, RemoteProcessingRequest request, boolean exportQueryScope, List<RemoteQueryClassDefinition> classList, long timeoutMillis, @Nullable QueryProcessorConnection.DisconnectHandler disconnectHandler, @Nullable com.fishlib.net.ConnectionMonitor.Params connectionMonitorParams) throws RemoteQueryException

Throws:

RemoteQueryException

getQueryProcessor

QueryProcessorConnection getQueryProcessor(boolean addClientClassesToClassPath, List<RemoteQueryClassDefinition> classList, long timeoutMillis) throws RemoteQueryException

Throws:

RemoteQueryException

getQueryProcessor

QueryProcessorConnection getQueryProcessor(RemoteProcessingRequest request, List<RemoteQueryClassDefinition> classList, long timeoutMillis) throws RemoteQueryException

Throws:

RemoteQueryException

getQueryProcessor

QueryProcessorConnection getQueryProcessor(RemoteProcessingRequest request, List<RemoteQueryClassDefinition> classList) throws RemoteQueryException

Throws:

RemoteQueryException

isConnected

boolean isConnected()

release

void release(boolean force) throws IOException

Throws:

IOException