com.pervasive.datarush.cluster

Class WorkerServer

java.lang.Object

com.pervasive.datarush.cluster.WorkerServer

public final class WorkerServer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	RESPONSE_MARKER

Constructor Summary

Constructors

Constructor and Description
WorkerServer(FileClient client, Path drfsBaseDir, String nodeID, JobServerInformation jobWorkerInfo, JobSpecifier jobSpecifier, ExecutorOptions execOptions, NodeAllocationProvider allocationProvider, String host)

Method Summary

Methods

Modifier and Type	Method and Description
void	awaitShutdown()
WorkerService	ensureService()
PathInfo	getDRFSBaseInfo()
static void	main(String[] argv)
void	shutdown()

Methods inherited from class java.lang.Object

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

Field Detail

RESPONSE_MARKER

public static final String RESPONSE_MARKER

See Also:

Constant Field Values

Constructor Detail

WorkerServer

public WorkerServer(FileClient client,
            Path drfsBaseDir,
            String nodeID,
            JobServerInformation jobWorkerInfo,
            JobSpecifier jobSpecifier,
            ExecutorOptions execOptions,
            NodeAllocationProvider allocationProvider,
            String host)

Method Detail

ensureService

public WorkerService ensureService()

shutdown

public void shutdown()

getDRFSBaseInfo

public PathInfo getDRFSBaseInfo()

awaitShutdown

public void awaitShutdown()
                   throws InterruptedException

Throws:

InterruptedException

main

public static void main(String[] argv)
                 throws Exception

Throws:

Exception