Package org.apache.hadoop.hbase.replication

Class ReplicationSourceDummy

java.lang.Object
org.apache.hadoop.hbase.replication.ReplicationSourceDummy
All Implemented Interfaces:
org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface
public class ReplicationSourceDummy extends Object implements org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface
Source that does nothing at all, helpful to test ReplicationSourceManager

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    private org.apache.hadoop.fs.Path
    currentPath
     
    private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager
    manager
     
    private org.apache.hadoop.hbase.replication.regionserver.MetricsSource
    metrics
     
    private org.apache.hadoop.hbase.replication.ReplicationQueueId
    queueId
     
    private org.apache.hadoop.hbase.replication.ReplicationPeer
    replicationPeer
     
    private AtomicBoolean
    startup
     
    private org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider
    walFileLengthProvider
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    ReplicationSourceDummy()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    addHFileRefs(org.apache.hadoop.hbase.TableName tableName, byte[] family, List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> files)
     
    void
    enqueueLog(org.apache.hadoop.fs.Path log)
     
    org.apache.hadoop.fs.Path
    getCurrentPath()
     
    org.apache.hadoop.hbase.replication.ReplicationPeer
    getPeer()
     
    String
    getPeerId()
     
    org.apache.hadoop.hbase.replication.ReplicationQueueId
    getQueueId()
     
    org.apache.hadoop.hbase.replication.ReplicationEndpoint
    getReplicationEndpoint()
     
    org.apache.hadoop.hbase.replication.ReplicationQueueStorage
    getReplicationQueueStorage()
     
    org.apache.hadoop.hbase.ServerName
    getServerWALsBelongTo()
     
    org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager
    getSourceManager()
     
    org.apache.hadoop.hbase.replication.regionserver.MetricsSource
    getSourceMetrics()
     
    String
    getStats()
     
    org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider
    getWALFileLengthProvider()
     
    void
    init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager manager, org.apache.hadoop.hbase.replication.ReplicationQueueStorage rq, org.apache.hadoop.hbase.replication.ReplicationPeer rp, org.apache.hadoop.hbase.Server server, org.apache.hadoop.hbase.replication.ReplicationQueueData queueData, UUID clusterId, org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider walFileLengthProvider, org.apache.hadoop.hbase.replication.regionserver.MetricsSource metrics)
     
    boolean
    isPeerEnabled()
     
    boolean
    isSourceActive()
     
    boolean
    isStartup()
     
    void
    postShipEdits(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, long batchSize)
     
    org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface
    startup()
     
    void
    terminate(String reason)
     
    void
    terminate(String reason, Exception e)
     
    void
    terminate(String reason, Exception e, boolean clearMetrics)
     
    void
    tryThrottle(int batchSize)
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    getWalGroupStatus, isRecovered, isSyncReplication, logPositionAndCleanOldLogs

  • Field Details

    • manager

      private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager manager

    • replicationPeer

      private org.apache.hadoop.hbase.replication.ReplicationPeer replicationPeer

    • queueId

      private org.apache.hadoop.hbase.replication.ReplicationQueueId queueId

    • currentPath

      private org.apache.hadoop.fs.Path currentPath

    • metrics

      private org.apache.hadoop.hbase.replication.regionserver.MetricsSource metrics

    • walFileLengthProvider

      private org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider walFileLengthProvider

    • startup

      private AtomicBoolean startup

  • Constructor Details

  • Method Details

    • init

      public void init(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager manager, org.apache.hadoop.hbase.replication.ReplicationQueueStorage rq, org.apache.hadoop.hbase.replication.ReplicationPeer rp, org.apache.hadoop.hbase.Server server, org.apache.hadoop.hbase.replication.ReplicationQueueData queueData, UUID clusterId, org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider walFileLengthProvider, org.apache.hadoop.hbase.replication.regionserver.MetricsSource metrics) throws IOException
      Specified by:
      init in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface
      Throws:
      IOException

    • enqueueLog

      public void enqueueLog(org.apache.hadoop.fs.Path log)
      Specified by:
      enqueueLog in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getCurrentPath

      public org.apache.hadoop.fs.Path getCurrentPath()
      Specified by:
      getCurrentPath in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • startup

      public org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface startup()
      Specified by:
      startup in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • isStartup

      public boolean isStartup()

    • terminate

      public void terminate(String reason)
      Specified by:
      terminate in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • terminate

      public void terminate(String reason, Exception e)
      Specified by:
      terminate in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • terminate

      public void terminate(String reason, Exception e, boolean clearMetrics)
      Specified by:
      terminate in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getQueueId

      public org.apache.hadoop.hbase.replication.ReplicationQueueId getQueueId()
      Specified by:
      getQueueId in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getPeerId

      public String getPeerId()
      Specified by:
      getPeerId in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getStats

      public String getStats()
      Specified by:
      getStats in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • addHFileRefs

      public void addHFileRefs(org.apache.hadoop.hbase.TableName tableName, byte[] family, List<org.apache.hadoop.hbase.util.Pair<org.apache.hadoop.fs.Path,org.apache.hadoop.fs.Path>> files) throws org.apache.hadoop.hbase.replication.ReplicationException
      Specified by:
      addHFileRefs in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface
      Throws:
      org.apache.hadoop.hbase.replication.ReplicationException

    • isPeerEnabled

      public boolean isPeerEnabled()
      Specified by:
      isPeerEnabled in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • isSourceActive

      public boolean isSourceActive()
      Specified by:
      isSourceActive in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getSourceMetrics

      public org.apache.hadoop.hbase.replication.regionserver.MetricsSource getSourceMetrics()
      Specified by:
      getSourceMetrics in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getReplicationEndpoint

      public org.apache.hadoop.hbase.replication.ReplicationEndpoint getReplicationEndpoint()
      Specified by:
      getReplicationEndpoint in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getSourceManager

      public org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager getSourceManager()
      Specified by:
      getSourceManager in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • tryThrottle

      public void tryThrottle(int batchSize) throws InterruptedException
      Specified by:
      tryThrottle in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface
      Throws:
      InterruptedException

    • postShipEdits

      public void postShipEdits(List<org.apache.hadoop.hbase.wal.WAL.Entry> entries, long batchSize)
      Specified by:
      postShipEdits in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getWALFileLengthProvider

      public org.apache.hadoop.hbase.replication.regionserver.WALFileLengthProvider getWALFileLengthProvider()
      Specified by:
      getWALFileLengthProvider in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getServerWALsBelongTo

      public org.apache.hadoop.hbase.ServerName getServerWALsBelongTo()
      Specified by:
      getServerWALsBelongTo in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getReplicationQueueStorage

      public org.apache.hadoop.hbase.replication.ReplicationQueueStorage getReplicationQueueStorage()
      Specified by:
      getReplicationQueueStorage in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface

    • getPeer

      public org.apache.hadoop.hbase.replication.ReplicationPeer getPeer()
      Specified by:
      getPeer in interface org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceInterface