Class ReplicationWorker

  • All Implemented Interfaces:
    java.lang.Runnable

    @StatsDoc(name="replication_worker",
              help="replication worker related stats")
    public class ReplicationWorker
    extends java.lang.Object
    implements java.lang.Runnable
    ReplicationWorker will take the fragments one by one from ZKLedgerUnderreplicationManager and replicates to it.