Package | Description |
---|---|
org.apache.hadoop.hbase.replication.regionserver |
Modifier and Type | Field and Description |
---|---|
private ReplicationSourceLogQueue |
WALEntryStream.logQueue |
private ReplicationSourceLogQueue |
ReplicationSourceWALReader.logQueue |
protected ReplicationSourceLogQueue |
ReplicationSourceShipper.logQueue |
protected ReplicationSourceLogQueue |
ReplicationSource.logQueue |
Constructor and Description |
---|
RecoveredReplicationSourceShipper(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.conf.Configuration conf,
long startPosition,
WALFileLengthProvider walFileLengthProvider,
ServerName serverName,
MetricsSource metrics,
String walGroupId)
Create an entry stream over the given queue at the given start position
|
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.