Package org.apache.bookkeeper.bookie.datainteg

Class DataIntegrityService

java.lang.Object

org.apache.bookkeeper.common.component.AbstractComponent<ConfT>

org.apache.bookkeeper.common.component.AbstractLifecycleComponent<BookieConfiguration>

org.apache.bookkeeper.bookie.datainteg.DataIntegrityService

All Implemented Interfaces:

java.lang.AutoCloseable, LifecycleComponent

public class DataIntegrityService
extends AbstractLifecycleComponent<BookieConfiguration>

An abstract lifecycle component that can perform data integrity checking.

Field Summary

Fields inherited from class org.apache.bookkeeper.common.component.AbstractLifecycleComponent

lifecycle, statsLogger, uncaughtExceptionHandler

Fields inherited from class org.apache.bookkeeper.common.component.AbstractComponent

componentName, conf

Constructor Summary

Constructors

Constructor	Description
DataIntegrityService(BookieConfiguration conf, StatsLogger statsLogger, DataIntegrityCheck check)

Method Summary

Modifier and Type	Method	Description
protected void	doClose()
protected void	doStart()
protected void	doStop()
protected int	interval()
protected java.util.concurrent.TimeUnit	intervalUnit()

Methods inherited from class org.apache.bookkeeper.common.component.AbstractLifecycleComponent

addLifecycleListener, close, getStatsLogger, lifecycleState, removeLifecycleListener, setExceptionHandler, start, stop

Methods inherited from class org.apache.bookkeeper.common.component.AbstractComponent

getConf, getName

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.bookkeeper.common.component.LifecycleComponent

getName, publishInfo

Constructor Detail

DataIntegrityService

public DataIntegrityService(BookieConfiguration conf,
                            StatsLogger statsLogger,
                            DataIntegrityCheck check)

Method Detail

interval

protected int interval()

intervalUnit

protected java.util.concurrent.TimeUnit intervalUnit()

doStart

protected void doStart()

Specified by:

doStart in class AbstractLifecycleComponent<BookieConfiguration>

doStop

protected void doStop()

Specified by:

doStop in class AbstractLifecycleComponent<BookieConfiguration>

doClose

protected void doClose()
                throws java.io.IOException

Specified by:

doClose in class AbstractLifecycleComponent<BookieConfiguration>

Throws:

java.io.IOException