Package org.apache.hadoop.hdfs.server.federation.store

Class StateStoreConnectionMonitorService

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.hdfs.server.federation.router.PeriodicService

org.apache.hadoop.hdfs.server.federation.store.StateStoreConnectionMonitorService

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service

public class StateStoreConnectionMonitorService
extends PeriodicService

Service to periodically monitor the connection of the StateStore StateStoreService data store and to re-open the connection to the data store if required.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Constructor Summary

Constructors

Constructor	Description
StateStoreConnectionMonitorService(StateStoreService store)	Create a new service to monitor the connectivity of the state store driver.

Method Summary

Modifier and Type	Method	Description
void	periodicInvoke()	Method that the service will run periodically.
protected void	serviceInit(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class org.apache.hadoop.hdfs.server.federation.router.PeriodicService

getErrorCount, getIntervalMs, getLastUpdate, getRunCount, serviceStart, serviceStop, setIntervalMs, startPeriodic, stopPeriodic

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Constructor Details

StateStoreConnectionMonitorService

public StateStoreConnectionMonitorService(StateStoreService store)

Create a new service to monitor the connectivity of the state store driver.

Parameters:

store - Instance of the state store to be monitored.

Method Details

serviceInit

protected void serviceInit(org.apache.hadoop.conf.Configuration conf)
                    throws Exception

Overrides:

serviceInit in class org.apache.hadoop.service.AbstractService

Throws:

Exception

periodicInvoke

public void periodicInvoke()

Description copied from class: PeriodicService

Method that the service will run periodically.

Specified by:

periodicInvoke in class PeriodicService