Uses of Class
org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceLogQueue
-
Uses of ReplicationSourceLogQueue in org.apache.hadoop.hbase.replication.regionserver
Modifier and TypeFieldDescriptionprotected ReplicationSourceLogQueue
ReplicationSource.logQueue
protected final ReplicationSourceLogQueue
ReplicationSourceShipper.logQueue
private final ReplicationSourceLogQueue
ReplicationSourceWALReader.logQueue
private final ReplicationSourceLogQueue
WALEntryStream.logQueue
ModifierConstructorDescriptionRecoveredReplicationSourceShipper
(org.apache.hadoop.conf.Configuration conf, String walGroupId, ReplicationSourceLogQueue logQueue, RecoveredReplicationSource source, ReplicationQueueStorage queueStorage) ReplicationSourceShipper
(org.apache.hadoop.conf.Configuration conf, String walGroupId, ReplicationSourceLogQueue logQueue, ReplicationSource source) ReplicationSourceWALReader
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, ReplicationSourceLogQueue logQueue, long startPosition, WALEntryFilter filter, ReplicationSource source, String walGroupId) Creates a reader worker for a given WAL queue.SerialReplicationSourceWALReader
(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, ReplicationSourceLogQueue logQueue, long startPosition, WALEntryFilter filter, ReplicationSource source, String walGroupId) WALEntryStream
(ReplicationSourceLogQueue logQueue, org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.conf.Configuration conf, long startPosition, WALFileLengthProvider walFileLengthProvider, MetricsSource metrics, String walGroupId) Create an entry stream over the given queue at the given start position