com.pervasive.datarush.cluster

Class JobMasterServiceImpl

java.lang.Object

com.pervasive.datarush.cluster.JobMasterServiceImpl

All Implemented Interfaces:

JobMasterService, MonitoredFutureService, WorkerService, SimpleRMI.ServerListener

public final class JobMasterServiceImpl
extends Object
implements SimpleRMI.ServerListener, JobMasterService

Constructor Summary

Constructors

Constructor and Description
JobMasterServiceImpl(FileClient fileClient, String nodeID, JobServerInformation jobWorkerInfo, StorageManagerSpecifier storageSpec, ClusterSpecifier clusterSpec, 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.
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)

Methods inherited from class java.lang.Object

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

Constructor Detail

JobMasterServiceImpl

public JobMasterServiceImpl(FileClient fileClient,
                    String nodeID,
                    JobServerInformation jobWorkerInfo,
                    StorageManagerSpecifier storageSpec,
                    ClusterSpecifier clusterSpec,
                    boolean wrap)

Method Detail

submit

public MonitoredFutureHandle submit(JobCallable<?> jobCallable)
                             throws RMIException,
                                    RMIInterruptedException

Specified by:

submit in interface JobMasterService

Throws:

RMIException

RMIInterruptedException

startShutdown

public void startShutdown(JobStatus status)
                   throws RemoteException

Specified by:

startShutdown in interface JobMasterService

Throws:

RemoteException

getFinalStatus

public JobStatus getFinalStatus()

getDiagnostic

public String getDiagnostic()

reportStatistics

protected void reportStatistics(JobStatistics statistics)

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