Package org.apache.bookkeeper.replication

Class ReplicationWorker

java.lang.Object

org.apache.bookkeeper.replication.ReplicationWorker

All Implemented Interfaces:

Runnable

@StatsDoc(name="replication_worker",
          help="replication worker related stats")
public class ReplicationWorker
extends Object
implements Runnable

ReplicationWorker will take the fragments one by one from ZKLedgerUnderreplicationManager and replicates to it.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	NUM_OF_EXPONENTIAL_BACKOFF_RETRIALS
(package private) final com.google.common.cache.LoadingCache<Long,AtomicInteger>	replicationFailedLedgers
(package private) final com.google.common.cache.LoadingCache<Long,ConcurrentSkipListSet<Long>>	unableToReadEntriesForReplication

Constructor Summary

Constructors

Constructor	Description
ReplicationWorker(ServerConfiguration conf)	Replication worker for replicating the ledger fragments from UnderReplicationManager to the targetBookie.
ReplicationWorker(ServerConfiguration conf, BookKeeper bkc, boolean ownBkc, StatsLogger statsLogger)
ReplicationWorker(ServerConfiguration conf, StatsLogger statsLogger)	Replication worker for replicating the ledger fragments from UnderReplicationManager to the targetBookie.

Method Summary

Modifier and Type	Method	Description
(package private) Set<LedgerFragment>	getUnderreplicatedFragments(LedgerHandle lh, Long ledgerVerificationPercentage)	Gets the under replicated fragments.
boolean	isRunning()	Gives the running status of ReplicationWorker.
void	run()
(package private) void	scheduleTaskWithDelay(TimerTask timerTask, long delayPeriod)
void	shutdown()	Stop the replication worker service.
void	start()	Start the replication worker.

Methods inherited from class java.lang.Object

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

Field Details

NUM_OF_EXPONENTIAL_BACKOFF_RETRIALS

public static final int NUM_OF_EXPONENTIAL_BACKOFF_RETRIALS

See Also:

• Constant Field Values

replicationFailedLedgers

final com.google.common.cache.LoadingCache<Long,AtomicInteger> replicationFailedLedgers

unableToReadEntriesForReplication

final com.google.common.cache.LoadingCache<Long,ConcurrentSkipListSet<Long>> unableToReadEntriesForReplication

Constructor Details

ReplicationWorker

public ReplicationWorker(ServerConfiguration conf)
                  throws ReplicationException.CompatibilityException,
ReplicationException.UnavailableException,
InterruptedException,
IOException

Replication worker for replicating the ledger fragments from UnderReplicationManager to the targetBookie. This target bookie will be a local bookie.

Parameters:

conf - - configurations

Throws:

ReplicationException.CompatibilityException

ReplicationException.UnavailableException

InterruptedException

IOException

ReplicationWorker

public ReplicationWorker(ServerConfiguration conf,
 StatsLogger statsLogger)
                  throws ReplicationException.CompatibilityException,
ReplicationException.UnavailableException,
InterruptedException,
IOException

Replication worker for replicating the ledger fragments from UnderReplicationManager to the targetBookie. This target bookie will be a local bookie.

Parameters:

conf - - configurations

statsLogger - - stats logger

Throws:

ReplicationException.CompatibilityException

ReplicationException.UnavailableException

InterruptedException

IOException

ReplicationWorker

ReplicationWorker(ServerConfiguration conf,
 BookKeeper bkc,
 boolean ownBkc,
 StatsLogger statsLogger)
           throws ReplicationException.CompatibilityException,
InterruptedException,
ReplicationException.UnavailableException

Throws:

ReplicationException.CompatibilityException

InterruptedException

ReplicationException.UnavailableException

Method Details

start

public void start()

Start the replication worker.

run

public void run()

Specified by:

run in interface Runnable

getUnderreplicatedFragments

Set<LedgerFragment> getUnderreplicatedFragments(LedgerHandle lh,
 Long ledgerVerificationPercentage)
                                         throws InterruptedException

Gets the under replicated fragments.

Throws:

InterruptedException

scheduleTaskWithDelay

void scheduleTaskWithDelay(TimerTask timerTask,
 long delayPeriod)

shutdown

public void shutdown()

Stop the replication worker service.

isRunning

public boolean isRunning()

Gives the running status of ReplicationWorker.