com.pervasive.datarush.cluster

Class DistributedWorkerServiceImpl

java.lang.Object

com.pervasive.datarush.cluster.DistributedWorkerServiceImpl

All Implemented Interfaces:

DistributedWorkerService, MonitoredFutureService, WorkerService, SimpleRMI.ServerListener

public final class DistributedWorkerServiceImpl
extends Object
implements SimpleRMI.ServerListener, DistributedWorkerService

Constructor Summary

Constructors

Constructor and Description
DistributedWorkerServiceImpl(NodeAllocationProvider allocationProvider, FileClient fileClient, String nodeID, JobServerInformation jobServerInfo, JobSpecifier jobSpec, boolean wrap)

Method Summary

Methods

Modifier and Type	Method and Description
CancelResult	cancel(GUID guid, boolean mayInterruptIfRunning)
boolean	deleteResult(GUID guid)
void	destroy() Called upon server shutdown.
DistributedCallableContextBatch	getBatchContext(List<NodeAllocationState.AssignmentState> assignments)
DistributedCallableContext	getContext(NodeAllocationState.AssignmentState assignment)
NodeStatistics	getStatistics()
String	getVersion() Returns the version number of this command service instance
void	init(GenericTCPServer.ServerContext context) Called upon server start to inform the handler of context information such as the listening address.
CommandStatus	poll(GUID resultGUID, long timeout, TimeUnit timeunit)
NodeStatistics	startShutdown()
MonitoredFutureHandle	submit(DistributedCallableBatch<?> command, List<NodeAllocationState.AssignmentState> assignments)

Methods inherited from class java.lang.Object

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

Constructor Detail

DistributedWorkerServiceImpl

public DistributedWorkerServiceImpl(NodeAllocationProvider allocationProvider,
                            FileClient fileClient,
                            String nodeID,
                            JobServerInformation jobServerInfo,
                            JobSpecifier jobSpec,
                            boolean wrap)

Method Detail

submit

public MonitoredFutureHandle submit(DistributedCallableBatch<?> command,
                           List<NodeAllocationState.AssignmentState> assignments)

Specified by:

submit in interface DistributedWorkerService

getContext

public DistributedCallableContext getContext(NodeAllocationState.AssignmentState assignment)

getBatchContext

public DistributedCallableContextBatch getBatchContext(List<NodeAllocationState.AssignmentState> assignments)

startShutdown

public NodeStatistics startShutdown()

Specified by:

startShutdown in interface DistributedWorkerService

init

public void init(GenericTCPServer.ServerContext context)

Description copied from interface: SimpleRMI.ServerListener

Called upon server start to inform the handler of context information such as the listening address. This method will be called prior to accepting any requests.

Specified by:

init in interface SimpleRMI.ServerListener

Parameters:

context - the server context

destroy

public void destroy()

Description copied from interface: SimpleRMI.ServerListener

Called upon server shutdown. This method will be called only after the last request has finished.

Specified by:

destroy in interface SimpleRMI.ServerListener

getStatistics

public NodeStatistics getStatistics()

Specified by:

getStatistics in interface WorkerService

getVersion

public String getVersion()

Description copied from interface: WorkerService

Returns the version number of this command service instance

Specified by:

getVersion in interface WorkerService

Returns:

poll

public CommandStatus poll(GUID resultGUID,
                 long timeout,
                 TimeUnit timeunit)
                   throws TaskNotFoundException,
                          InterruptedException

Specified by:

poll in interface MonitoredFutureService

Throws:

TaskNotFoundException

InterruptedException

deleteResult

public boolean deleteResult(GUID guid)

Specified by:

deleteResult in interface MonitoredFutureService

cancel

public CancelResult cancel(GUID guid,
                  boolean mayInterruptIfRunning)
                    throws TaskNotFoundException

Specified by:

cancel in interface MonitoredFutureService

Throws:

TaskNotFoundException