Package | Description |
---|---|
org.apache.hadoop.hbase.protobuf |
Holds classes generated from protobuf
src/main/protobuf definition files. |
org.apache.hadoop.hbase.regionserver.wal | |
org.apache.hadoop.hbase.replication |
Multi Cluster Replication
|
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.wal |
Modifier and Type | Method and Description |
---|---|
static Pair<AdminProtos.ReplicateWALEntryRequest,CellScanner> |
ReplicationProtbufUtil.buildReplicateWALEntryRequest(WAL.Entry[] entries)
Create a new ReplicateWALEntryRequest from a list of WAL entries
|
static Pair<AdminProtos.ReplicateWALEntryRequest,CellScanner> |
ReplicationProtbufUtil.buildReplicateWALEntryRequest(WAL.Entry[] entries,
byte[] encodedRegionName,
String replicationClusterId,
org.apache.hadoop.fs.Path sourceBaseNamespaceDir,
org.apache.hadoop.fs.Path sourceHFileArchiveDir)
Create a new ReplicateWALEntryRequest from a list of WAL entries
|
static void |
ReplicationProtbufUtil.replicateWALEntry(AdminProtos.AdminService.BlockingInterface admin,
WAL.Entry[] entries,
String replicationClusterId,
org.apache.hadoop.fs.Path sourceBaseNamespaceDir,
org.apache.hadoop.fs.Path sourceHFileArchiveDir)
A helper to replicate a list of WAL entries using admin protocol.
|
Modifier and Type | Method and Description |
---|---|
WAL.Entry |
ReaderBase.next() |
WAL.Entry |
ReaderBase.next(WAL.Entry reuse) |
Modifier and Type | Method and Description |
---|---|
void |
ProtobufLogWriter.append(WAL.Entry entry) |
void |
AsyncProtobufLogWriter.append(WAL.Entry entry) |
WAL.Entry |
ReaderBase.next(WAL.Entry reuse) |
protected abstract boolean |
ReaderBase.readNext(WAL.Entry e)
Read next entry.
|
protected boolean |
ProtobufLogReader.readNext(WAL.Entry entry) |
Modifier and Type | Method and Description |
---|---|
WAL.Entry |
ChainWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
SystemTableWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ScopeWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ClusterMarkingEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
NamespaceTableCfWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
WALEntryFilter.filter(WAL.Entry entry)
Applies the filter, possibly returning a different Entry instance.
|
Modifier and Type | Method and Description |
---|---|
List<WAL.Entry> |
ReplicationEndpoint.ReplicateContext.getEntries() |
Modifier and Type | Method and Description |
---|---|
WAL.Entry |
ChainWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
SystemTableWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ScopeWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ClusterMarkingEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
NamespaceTableCfWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
WALEntryFilter.filter(WAL.Entry entry)
Applies the filter, possibly returning a different Entry instance.
|
Cell |
ScopeWALEntryFilter.filterCell(WAL.Entry entry,
Cell cell) |
Cell |
WALCellFilter.filterCell(WAL.Entry entry,
Cell cell)
Applies the filter, possibly returning a different Cell instance.
|
Cell |
NamespaceTableCfWALEntryFilter.filterCell(WAL.Entry entry,
Cell cell) |
Modifier and Type | Method and Description |
---|---|
ReplicationEndpoint.ReplicateContext |
ReplicationEndpoint.ReplicateContext.setEntries(List<WAL.Entry> entries) |
Modifier and Type | Method and Description |
---|---|
protected Callable<Integer> |
HBaseInterClusterReplicationEndpoint.createReplicator(List<WAL.Entry> entries,
int batchIndex) |
void |
ReplicationSource.postShipEdits(List<WAL.Entry> entries,
int batchSize) |
void |
ReplicationSourceInterface.postShipEdits(List<WAL.Entry> entries,
int batchSize)
Call this after the shipper thread ship some entries to peer cluster.
|
protected int |
HBaseInterClusterReplicationEndpoint.replicateEntries(List<WAL.Entry> entries,
int batchIndex) |
Modifier and Type | Method and Description |
---|---|
WAL.Entry |
WAL.Reader.next() |
WAL.Entry |
WAL.Reader.next(WAL.Entry reuse) |
Modifier and Type | Method and Description |
---|---|
List<WAL.Entry> |
WALSplitter.RegionEntryBuffer.getEntryBuffer() |
Modifier and Type | Method and Description |
---|---|
void |
WALProvider.Writer.append(WAL.Entry entry) |
void |
WALProvider.AsyncWriter.append(WAL.Entry entry) |
void |
WALSplitter.EntryBuffers.appendEntry(WAL.Entry entry)
Append a log entry into the corresponding region buffer.
|
abstract boolean |
WALSplitter.OutputSink.keepRegionEvent(WAL.Entry entry)
Some WALEdit's contain only KV's for account on what happened to a region.
|
WAL.Entry |
WAL.Reader.next(WAL.Entry reuse) |
Copyright © 2007–2019 Cloudera. All rights reserved.