| 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<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryRequest,CellScanner> |
ReplicationProtbufUtil.buildReplicateWALEntryRequest(WAL.Entry[] entries)
Create a new ReplicateWALEntryRequest from a list of WAL entries
|
static Pair<org.apache.hadoop.hbase.protobuf.generated.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 HLog entries
|
static void |
ReplicationProtbufUtil.replicateWALEntry(org.apache.hadoop.hbase.protobuf.generated.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) |
WAL.Entry |
ReaderBase.next(WAL.Entry reuse) |
protected abstract boolean |
ReaderBase.readNext(WAL.Entry e)
Read next entry.
|
protected boolean |
SequenceFileLogReader.readNext(WAL.Entry e)
fill in the passed entry with teh next key/value.
|
protected boolean |
ProtobufLogReader.readNext(WAL.Entry entry) |
| Modifier and Type | Method and Description |
|---|---|
void |
WALEditsReplaySink.replayEntries(List<Pair<HRegionLocation,WAL.Entry>> entries)
Replay an array of actions of the same region directly into the newly assigned Region Server
|
| Modifier and Type | Method and Description |
|---|---|
WAL.Entry |
SystemTableWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ChainWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
TableCfWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ClusterMarkingEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ScopeWALEntryFilter.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 |
SystemTableWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ChainWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
TableCfWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ClusterMarkingEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ScopeWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
WALEntryFilter.filter(WAL.Entry entry)
Applies the filter, possibly returning a different Entry instance.
|
Cell |
WALCellFilter.filterCell(WAL.Entry entry,
Cell cell)
Applies the filter, possibly returning a different Cell instance.
|
Cell |
TableCfWALEntryFilter.filterCell(WAL.Entry entry,
Cell cell) |
Cell |
ScopeWALEntryFilter.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 |
|---|---|
WAL.Entry |
WALEntryStream.next() |
| Modifier and Type | Method and Description |
|---|---|
Iterator<WAL.Entry> |
WALEntryStream.iterator() |
| Modifier and Type | Method and Description |
|---|---|
protected HBaseInterClusterReplicationEndpoint.Replicator |
HBaseInterClusterReplicationEndpoint.createReplicator(List<WAL.Entry> entries,
int ordinal) |
protected void |
HBaseInterClusterReplicationEndpoint.Replicator.replicateEntries(org.apache.hadoop.hbase.protobuf.generated.AdminProtos.AdminService.BlockingInterface rrs,
List<WAL.Entry> batch,
String replicationClusterId,
org.apache.hadoop.fs.Path baseNamespaceDir,
org.apache.hadoop.fs.Path hfileArchiveDir) |
| Constructor and Description |
|---|
HBaseInterClusterReplicationEndpoint.Replicator(List<WAL.Entry> entries,
int ordinal) |
| 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 |
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 The Apache Software Foundation. All rights reserved.