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, io.deephaven.enterprise.auth.TokenFactoryFactory tokenAuthenticationManager)
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
 io.deephaven.enterprise.auth.TokenFactoryFactory tokenAuthenticationManager)
                                    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