Class RemoteQueryScopeCommandHandler
java.lang.Object
com.illumon.iris.db.tables.remote.RemoteQueryScopeCommandHandler
- All Implemented Interfaces:
QueryProcessorConnection.QueryProcessorConnectionCommandHandler
public class RemoteQueryScopeCommandHandler
extends Object
implements QueryProcessorConnection.QueryProcessorConnectionCommandHandler
-
Constructor Summary
ConstructorsConstructorDescriptionRemoteQueryScopeCommandHandler
(QueryProcessorConnection processorConnection, com.fishlib.io.logger.Logger log) -
Method Summary
Modifier and TypeMethodDescriptionvoid
handleClientDeath
(io.deephaven.enterprise.comm.api.ClientEntry client) Called when a client dies.boolean
handleQueryProcessorCommand
(io.deephaven.enterprise.comm.api.ClientEntry clientEntry, com.fishlib.base.Command command) Handles a command from the remote query processor that the query processor connection itself does not know how to handle.void
updateVariables
(Map<String, Object> remotelyChangedValues)
-
Constructor Details
-
RemoteQueryScopeCommandHandler
public RemoteQueryScopeCommandHandler(QueryProcessorConnection processorConnection, com.fishlib.io.logger.Logger log) throws IOException - Throws:
IOException
-
-
Method Details
-
getParamMetadata
-
updateVariables
-
handleClientDeath
public void handleClientDeath(io.deephaven.enterprise.comm.api.ClientEntry client) Description copied from interface:QueryProcessorConnection.QueryProcessorConnectionCommandHandler
Called when a client dies.- Specified by:
handleClientDeath
in interfaceQueryProcessorConnection.QueryProcessorConnectionCommandHandler
- Parameters:
client
- the clientEntry that died.
-
handleQueryProcessorCommand
public boolean handleQueryProcessorCommand(io.deephaven.enterprise.comm.api.ClientEntry clientEntry, com.fishlib.base.Command command) Description copied from interface:QueryProcessorConnection.QueryProcessorConnectionCommandHandler
Handles a command from the remote query processor that the query processor connection itself does not know how to handle. If true is returned, then no other attached QueryProcessorConnectionCommandHandler has an opportunity to examine the command. If false is returned, the next attached QueryProcessorConnectionCommandHandler is given an opportunity to service this command.- Specified by:
handleQueryProcessorCommand
in interfaceQueryProcessorConnection.QueryProcessorConnectionCommandHandler
- Parameters:
clientEntry
- the client entry for the remote query processorcommand
- the command that was sent by the remote query processor- Returns:
- true if the command was handled, false otherwise
-