org.apache.hadoop.hbase.replication.regionserver

Class CatalogReplicationSource

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.ReplicationSource

org.apache.hadoop.hbase.replication.regionserver.CatalogReplicationSource

All Implemented Interfaces:

ReplicationSourceInterface

@InterfaceAudience.Private
class CatalogReplicationSource
extends ReplicationSource

ReplicationSource that reads catalog WAL files -- e.g. hbase:meta WAL files -- and lets through all WALEdits from these WALs. This ReplicationSource is NOT created via ReplicationSourceFactory.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.replication.regionserver.ReplicationSource

conf, DEFAULT_WAIT_ON_ENDPOINT_SECONDS, fs, manager, queueId, queueSizePerGroup, queueStorage, replicationPeer, replicationQueueInfo, server, WAIT_ON_ENDPOINT_SECONDS, walEntryFilter, workerThreads

Constructor Summary

Constructors

Constructor and Description
CatalogReplicationSource()

Method Summary

Modifier and Type	Method and Description
void	logPositionAndCleanOldLogs(WALEntryBatch entryBatch) Log the current position to storage.

Methods inherited from class org.apache.hadoop.hbase.replication.regionserver.ReplicationSource

addHFileRefs, createNewShipper, enqueueLog, getCurrentPath, getPeerId, getQueueId, getReplicationEndpoint, getReplicationQueueInfo, getReplicationQueueStorage, getServer, getServerWALsBelongTo, getSourceManager, getSourceMetrics, getStats, getWalEntryFilter, getWALFileLengthProvider, getWalGroupStatus, init, isPeerEnabled, isSourceActive, isWorkerRunning, postShipEdits, sleepForRetries, startup, terminate, terminate, terminate, terminate, tryThrottle, uncaughtException

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

isRecovered

Constructor Detail

CatalogReplicationSource

CatalogReplicationSource()

Method Detail

logPositionAndCleanOldLogs

public void logPositionAndCleanOldLogs(WALEntryBatch entryBatch)

Description copied from interface: ReplicationSourceInterface

Log the current position to storage. Also clean old logs from the replication queue. Use to bypass the default call to ReplicationSourceManager.logPositionAndCleanOldLogs(ReplicationSourceInterface, WALEntryBatch) whem implementation does not need to persist state to backing storage.

Parameters:

entryBatch - the wal entry batch we just shipped