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
Direct Known Subclasses:
TestReplicationSourceManager.FailInitializeDummyReplicationSource
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
    (package private) org.apache.hadoop.fs.Path
    currentPath
     
    (package private) org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager
    manager
     
    (package private) org.apache.hadoop.hbase.replication.regionserver.MetricsSource
    metrics
     
    (package private) String
    peerClusterId
     
    (package private) AtomicBoolean
    startup
     
    (package 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()
     
    String
    getPeerId()
     
    String
    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, String peerClusterId, 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, logPositionAndCleanOldLogs

  • Field Details

  • 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, String peerClusterId, 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 String 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