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 File`	`getCachedClassDirectory()`
`static File`	`getCachedClassDirectory(String processUserName)`
`static File`	`getClassDirectoryRoot()`
`static File`	`getClassDirectoryRoot(String processUserName)`
`static String`	`getUserWorkspaceRoot(String processUserName)`
`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()
- shutdown
  
  public boolean shutdown()
- main
  
  public static void main(String... args)