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

Class RemoteQueryDispatcher

java.lang.Object

com.illumon.iris.db.tables.remotequery.RemoteQueryDispatcher

public class RemoteQueryDispatcher
extends Object

Dispatcher class to create query workers.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RemoteQueryDispatcher.RunState

Field Summary

Fields

Modifier and Type	Field	Description
static boolean	ALLOW_RUN_AS
static String	DISPATCHER_ETCD_RW_CONTEXT	The name of the directory under /etc/sysconfig/deephaven/etcd/client/ that contains our etcd endpoint, user, password, certificate, etc.
static int	LEASE_KEEPALIVE_TIMEOUT_MS	How long will we wait for our etcd lease to be granted or renewed, in milliseconds before determining that we had a failure.
static long	prefixNonce

Constructor Summary

Constructors

Constructor	Description
RemoteQueryDispatcher(IrisLogCreator logCreator, String dispatcherHostName)

Method Summary

Modifier and Type	Method	Description
static io.deephaven.shadow.jackson.com.fasterxml.jackson.databind.node.ArrayNode	generateWorkerKindJson(Map<String,WorkerKind> map)
static File	getCachedClassDirectory()
static File	getCachedClassDirectory(String processUserName)
static File	getClassDirectoryRoot()
static File	getClassDirectoryRoot(String processUserName)
static String	getUserWorkspaceRoot(String processUserName)
static Map<String,WorkerKind>	getWorkerKindMap(com.fishlib.io.logger.Logger log, com.fishlib.configuration.Configuration configuration)	Produce the map of worker kind objects that the dispatcher supports.
static void	main(String... args)
boolean	shutdown()

Methods inherited from class java.lang.Object

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

Field Details

DISPATCHER_ETCD_RW_CONTEXT

public static final String DISPATCHER_ETCD_RW_CONTEXT

The name of the directory under /etc/sysconfig/deephaven/etcd/client/ that contains our etcd endpoint, user, password, certificate, etc.

See Also:

Constant Field Values

LEASE_KEEPALIVE_TIMEOUT_MS

public static final int LEASE_KEEPALIVE_TIMEOUT_MS

How long will we wait for our etcd lease to be granted or renewed, in milliseconds before determining that we had a failure.

prefixNonce

public static final long prefixNonce

ALLOW_RUN_AS

public static boolean ALLOW_RUN_AS

Constructor Details

RemoteQueryDispatcher

public RemoteQueryDispatcher(IrisLogCreator logCreator, String dispatcherHostName) throws IOException, ExecutionException, InterruptedException, TimeoutException

Throws:

IOException

ExecutionException

InterruptedException

TimeoutException

Method Details

getUserWorkspaceRoot

public static String getUserWorkspaceRoot(String processUserName)

getClassDirectoryRoot

public static File getClassDirectoryRoot(String processUserName)

getClassDirectoryRoot

public static File getClassDirectoryRoot()

getCachedClassDirectory

public static File getCachedClassDirectory(String processUserName)

getCachedClassDirectory

public static File getCachedClassDirectory()

getWorkerKindMap

@NotNull public static Map<String,WorkerKind> getWorkerKindMap(com.fishlib.io.logger.Logger log, com.fishlib.configuration.Configuration configuration)

Produce the map of worker kind objects that the dispatcher supports.

Parameters:

configuration - the configuration object

Returns:

a Map from name to WorkerKind

generateWorkerKindJson

public static io.deephaven.shadow.jackson.com.fasterxml.jackson.databind.node.ArrayNode generateWorkerKindJson(@NotNull Map<String,WorkerKind> map)

Parameters:

map - map from WorkerKind name to WorkerKind object

Returns:

JSON string to send to web API and other clients

shutdown

public boolean shutdown()

main

public static void main(String... args)