com.bigdata.service.mapred.jini
Class MapServer.AdministrableMapService

java.lang.Object
  com.bigdata.service.mapred.AbstractJobAndTaskService<MapJobMetadata,AbstractMapTask>
      com.bigdata.service.mapred.MapService
          com.bigdata.service.mapred.jini.MapServer.AdministrableMapService

All Implemented Interfaces:

IServiceShutdown, RemoteAdministrable, RemoteDestroyAdmin, IJobAndTaskService<MapJobMetadata,AbstractMapTask>, IMapService, com.sun.jini.admin.DestroyAdmin, Remote, net.jini.admin.Administrable

Enclosing class:

MapServer

public static class MapServer.AdministrableMapService
extends MapService
implements RemoteAdministrable, RemoteDestroyAdmin

Adds jini administration interfaces to the basic MapService.

Version:

$Id$

Author:

Bryan Thompson

TODO:

define the MDC logging context in the base class and extend it here.

Nested Class Summary

Nested classes/interfaces inherited from class com.bigdata.service.mapred.MapService

MapService.EmbeddedMapService, MapService.Options

Nested classes/interfaces inherited from class com.bigdata.service.mapred.AbstractJobAndTaskService

AbstractJobAndTaskService.AbstractTaskWorker<M,T extends ITask>

Field Summary

protected AbstractServer

server

Fields inherited from class com.bigdata.service.mapred.MapService

log

Fields inherited from class com.bigdata.service.mapred.AbstractJobAndTaskService

cancelService, ERR_JOB_EXISTS, ERR_NO_JOB_IDENTIFIER, ERR_NO_SUCH_JOB, heartbeatMonitor, heartbeatPeriod, heartbeatTimeout, jobs, taskService, threadPoolSize, timeoutService

Constructor Summary

MapServer.AdministrableMapService(AbstractServer server, Properties properties)

Method Summary

void	destroy() This DESTROYS the persistent state of the service. YOU CAN NOT restart the service after calling this method.
Object	getAdmin()
JiniClient<?>	getBigdataClient()
JiniFederation<?>	getFederation()
UUID	getServiceUUID() The unique identifier for this service.
void	shutdown() The service will no longer accept new requests, but existing requests will be processed (sychronous).
void	shutdownNow() The service will no longer accept new requests and will make a best effort attempt to terminate all existing requests and return ASAP.

Methods inherited from class com.bigdata.service.mapred.MapService

newTaskWorker

Methods inherited from class com.bigdata.service.mapred.AbstractJobAndTaskService

cancel, cancelJob, drain, heartbeat, isOpen, newJobState, startJob, submit

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.bigdata.service.mapred.IJobAndTaskService

cancel, cancelJob, drain, heartbeat, startJob, submit

Methods inherited from interface com.bigdata.service.IServiceShutdown

isOpen

Field Detail

server

protected final AbstractServer server

Constructor Detail

MapServer.AdministrableMapService

public MapServer.AdministrableMapService(AbstractServer server,
                                         Properties properties)

Method Detail

getAdmin

public Object getAdmin()
                throws RemoteException

Specified by:

getAdmin in interface net.jini.admin.Administrable

Throws:

RemoteException

destroy

public void destroy()

Description copied from interface: RemoteDestroyAdmin

This DESTROYS the persistent state of the service. YOU CAN NOT restart the service after calling this method. All persistent state (including any application data) WILL BE DESTROYED.

Specified by:

destroy in interface RemoteDestroyAdmin

Specified by:

destroy in interface com.sun.jini.admin.DestroyAdmin

Overrides:

destroy in class AbstractJobAndTaskService<MapJobMetadata,AbstractMapTask>

shutdown

public void shutdown()

Description copied from interface: IServiceShutdown

The service will no longer accept new requests, but existing requests will be processed (sychronous). This method should await the termination of pending requests, but no longer than the timeout specified by IServiceShutdown.Options.SHUTDOWN_TIMEOUT. Implementations SHOULD be synchronized. If the service is aleady shutdown, then this method should be a NOP.

Specified by:

shutdown in interface IServiceShutdown

Specified by:

shutdown in interface RemoteDestroyAdmin

Overrides:

shutdown in class AbstractJobAndTaskService<MapJobMetadata,AbstractMapTask>

shutdownNow

public void shutdownNow()

Description copied from interface: IServiceShutdown

The service will no longer accept new requests and will make a best effort attempt to terminate all existing requests and return ASAP. This method should terminate any asynchronous processing, release all resources and return immediately. Implementations SHOULD be synchronized. If the service is aleady shutdown, then this method should be a NOP.

Specified by:

shutdownNow in interface IServiceShutdown

Specified by:

shutdownNow in interface RemoteDestroyAdmin

Overrides:

shutdownNow in class AbstractJobAndTaskService<MapJobMetadata,AbstractMapTask>

getServiceUUID

public UUID getServiceUUID()

Description copied from interface: IJobAndTaskService

The unique identifier for this service.

Specified by:

getServiceUUID in interface IJobAndTaskService<MapJobMetadata,AbstractMapTask>

Returns:

The unique service identifier.

getBigdataClient

public JiniClient<?> getBigdataClient()

Specified by:

getBigdataClient in class AbstractJobAndTaskService<MapJobMetadata,AbstractMapTask>

Returns:

The client used to read/write data.

getFederation

public JiniFederation<?> getFederation()