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

Class EnterpriseWorkerKind

java.lang.Object

com.illumon.iris.db.tables.remotequery.EnterpriseWorkerKind

All Implemented Interfaces:

LocalProcessWorkerKind, WorkerKind

public class EnterpriseWorkerKind
extends Object
implements WorkerKind, LocalProcessWorkerKind

Basic worker control for Deephaven Enterprise workers, running the same version as the Dispatcher.

Field Summary

Fields inherited from interface com.illumon.iris.db.tables.remotequery.WorkerKind

DEFAULT

Constructor Summary

Constructors

Constructor	Description
EnterpriseWorkerKind(String name)

Method Summary

Modifier and Type	Method	Description
List<String>	getBaseCommand(String workerCreationJson, String processUserName, List<String> runAsParams)	Create the beginning of the new worker's command.
String	getWorkerControlTypeForRequest(RemoteProcessingRequest request)	The worker control type required for a particular request.
boolean	includeArtifactArguments()	Some customers have custom artifacts per user, which are passed to the Enterprise start script with the -u, -t, and -r options.
boolean	includeExtraClassPaths()	True if temporary dispatcher produced class paths should be included on the command line with -C.
boolean	includeNameArgument()	True if -A "name" should be included on the command line.
boolean	needsDheJvmFlags()	Does this produce a JVM that requires DHE specific JVM arguments
boolean	needsJavaOptsEnv()	Does this produce a JVM that requires JVM arguments via a JAVA_OPTS environment variable.
boolean	needsJvmFlags()	Does this produce a JVM that requires JVM like arguments
Collection<String>	workerControlTypes()	What kind of worker controls could be required for starting these kind of workers?

Methods inherited from class java.lang.Object

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

Constructor Details

EnterpriseWorkerKind

public EnterpriseWorkerKind(String name)

Method Details

workerControlTypes

public Collection<String> workerControlTypes()

Description copied from interface: WorkerKind

What kind of worker controls could be required for starting these kind of workers?

Specified by:

workerControlTypes in interface WorkerKind

Returns:

the desired WorkerControlType

getWorkerControlTypeForRequest

public String getWorkerControlTypeForRequest(RemoteProcessingRequest request)

Description copied from interface: WorkerKind

The worker control type required for a particular request.

Specified by:

getWorkerControlTypeForRequest in interface WorkerKind

Parameters:

request - the request that a worker is being created for

Returns:

the type of worker control for this particular request

needsJvmFlags

public boolean needsJvmFlags()

Description copied from interface: LocalProcessWorkerKind

Does this produce a JVM that requires JVM like arguments

Specified by:

needsJvmFlags in interface LocalProcessWorkerKind

Returns:

true if this kind of worker needs JVM arguments

needsDheJvmFlags

public boolean needsDheJvmFlags()

Description copied from interface: LocalProcessWorkerKind

Does this produce a JVM that requires DHE specific JVM arguments

Specified by:

needsDheJvmFlags in interface LocalProcessWorkerKind

Returns:

true if this kind of worker needs DHE specific JVM arguments

needsJavaOptsEnv

public boolean needsJavaOptsEnv()

Description copied from interface: LocalProcessWorkerKind

Does this produce a JVM that requires JVM arguments via a JAVA_OPTS environment variable.

Specified by:

needsJavaOptsEnv in interface LocalProcessWorkerKind

Returns:

true if this kind of worker needs a JAVA_OPTS environment variable.

includeNameArgument

public boolean includeNameArgument()

Description copied from interface: LocalProcessWorkerKind

True if -A "name" should be included on the command line.

Specified by:

includeNameArgument in interface LocalProcessWorkerKind

Returns:

true if the name argument is included

includeExtraClassPaths

public boolean includeExtraClassPaths()

Description copied from interface: LocalProcessWorkerKind

True if temporary dispatcher produced class paths should be included on the command line with -C.

Specified by:

includeExtraClassPaths in interface LocalProcessWorkerKind

Returns:

true if the dispatcher's temporary classpaths should be included

includeArtifactArguments

public boolean includeArtifactArguments()

Description copied from interface: LocalProcessWorkerKind

Some customers have custom artifacts per user, which are passed to the Enterprise start script with the -u, -t, and -r options. True if those options be included in the command.

Specified by:

includeArtifactArguments in interface LocalProcessWorkerKind

Returns:

true if -u, -t, and -r options should be included

getBaseCommand

public List<String> getBaseCommand(String workerCreationJson, String processUserName, List<String> runAsParams)

Description copied from interface: LocalProcessWorkerKind

Create the beginning of the new worker's command.

Specified by:

getBaseCommand in interface LocalProcessWorkerKind

Parameters:

workerCreationJson - the JSON passed by the remote processing request

processUserName - the user name that the process will execute as

runAsParams - the parameters for running as a distinct system user

Returns:

a new list with the beginning of the command to execute