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)
Create a new ReplicateWALEntryRequest from a list of HLog entries
|
static void |
ReplicationProtbufUtil.replicateWALEntry(AdminProtos.AdminService.BlockingInterface admin,
WAL.Entry[] entries)
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 boolean |
SequenceFileLogReader.readNext(WAL.Entry e)
fill in the passed entry with teh next key/value.
|
protected abstract boolean |
ReaderBase.readNext(WAL.Entry e)
Read next entry.
|
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 |
WALEntryFilter.filter(WAL.Entry entry)
Applies the filter, possibly returning a different Entry instance.
|
WAL.Entry |
TableCfWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
SystemTableWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ScopeWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ChainWALEntryFilter.filter(WAL.Entry entry) |
Modifier and Type | Method and Description |
---|---|
List<WAL.Entry> |
ReplicationEndpoint.ReplicateContext.getEntries() |
Modifier and Type | Method and Description |
---|---|
WAL.Entry |
WALEntryFilter.filter(WAL.Entry entry)
Applies the filter, possibly returning a different Entry instance.
|
WAL.Entry |
TableCfWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
SystemTableWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ScopeWALEntryFilter.filter(WAL.Entry entry) |
WAL.Entry |
ChainWALEntryFilter.filter(WAL.Entry entry) |
Modifier and Type | Method and Description |
---|---|
ReplicationEndpoint.ReplicateContext |
ReplicationEndpoint.ReplicateContext.setEntries(List<WAL.Entry> entries) |
Modifier and Type | Method and Description |
---|---|
WAL.Entry |
ReplicationWALReaderManager.readNextAndSetPosition()
Get the next entry, returned and also added in the array
|
Modifier and Type | Method and Description |
---|---|
protected boolean |
ReplicationSource.readAllEntriesToReplicateOrNextFile(boolean currentWALisBeingWrittenTo,
List<WAL.Entry> entries)
Read all the entries from the current log files and retain those
that need to be replicated.
|
protected void |
ReplicationSource.shipEdits(boolean currentWALisBeingWrittenTo,
List<WAL.Entry> entries)
Do the shipping logic
|
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.
|
WAL.Entry |
WAL.Reader.next(WAL.Entry reuse) |
Copyright © 2007-2016 The Apache Software Foundation. All Rights Reserved.