public final class DistributedWorkerServiceImpl extends Object implements SimpleRMI.ServerListener, DistributedWorkerService
Constructor and Description |
---|
DistributedWorkerServiceImpl(NodeAllocationProvider allocationProvider,
FileClient fileClient,
String nodeID,
JobServerInformation jobServerInfo,
JobSpecifier jobSpec,
boolean wrap) |
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) |
public DistributedWorkerServiceImpl(NodeAllocationProvider allocationProvider, FileClient fileClient, String nodeID, JobServerInformation jobServerInfo, JobSpecifier jobSpec, boolean wrap)
public MonitoredFutureHandle submit(DistributedCallableBatch<?> command, List<NodeAllocationState.AssignmentState> assignments)
submit
in interface DistributedWorkerService
public DistributedCallableContext getContext(NodeAllocationState.AssignmentState assignment)
public DistributedCallableContextBatch getBatchContext(List<NodeAllocationState.AssignmentState> assignments)
public NodeStatistics startShutdown()
startShutdown
in interface DistributedWorkerService
public void init(GenericTCPServer.ServerContext context)
SimpleRMI.ServerListener
init
in interface SimpleRMI.ServerListener
context
- the server contextpublic void destroy()
SimpleRMI.ServerListener
destroy
in interface SimpleRMI.ServerListener
public NodeStatistics getStatistics()
getStatistics
in interface WorkerService
public String getVersion()
WorkerService
getVersion
in interface WorkerService
public CommandStatus poll(GUID resultGUID, long timeout, TimeUnit timeunit) throws TaskNotFoundException, InterruptedException
poll
in interface MonitoredFutureService
TaskNotFoundException
InterruptedException
public boolean deleteResult(GUID guid)
deleteResult
in interface MonitoredFutureService
public CancelResult cancel(GUID guid, boolean mayInterruptIfRunning) throws TaskNotFoundException
cancel
in interface MonitoredFutureService
TaskNotFoundException
Copyright © 2015 Actian Corporation. All Rights Reserved.