public final class JobMasterServiceImpl extends Object implements SimpleRMI.ServerListener, JobMasterService
Constructor and Description |
---|
JobMasterServiceImpl(FileClient fileClient,
String nodeID,
JobServerInformation jobWorkerInfo,
StorageManagerSpecifier storageSpec,
ClusterSpecifier clusterSpec,
boolean wrap) |
Modifier and Type | Method and Description |
---|---|
CancelResult |
cancel(GUID guid,
boolean mayInterruptIfRunning) |
boolean |
deleteResult(GUID guid) |
void |
destroy()
Called upon server shutdown.
|
String |
getDiagnostic() |
JobStatus |
getFinalStatus() |
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) |
protected void |
reportStatistics(JobStatistics statistics) |
void |
startShutdown(JobStatus status) |
MonitoredFutureHandle |
submit(JobCallable<?> jobCallable) |
public JobMasterServiceImpl(FileClient fileClient, String nodeID, JobServerInformation jobWorkerInfo, StorageManagerSpecifier storageSpec, ClusterSpecifier clusterSpec, boolean wrap)
public MonitoredFutureHandle submit(JobCallable<?> jobCallable) throws RMIException, RMIInterruptedException
submit
in interface JobMasterService
RMIException
RMIInterruptedException
public void startShutdown(JobStatus status) throws RemoteException
startShutdown
in interface JobMasterService
RemoteException
public JobStatus getFinalStatus()
public String getDiagnostic()
protected void reportStatistics(JobStatistics statistics)
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 © 2016 Actian Corporation. All Rights Reserved.