Package | Description |
---|---|
org.apache.hadoop.hbase.coprocessor |
Table of Contents
|
org.apache.hadoop.hbase.protobuf.generated | |
org.apache.hadoop.hbase.regionserver | |
org.apache.hadoop.hbase.replication.regionserver | |
org.apache.hadoop.hbase.security.access | |
org.apache.hadoop.hbase.wal |
Modifier and Type | Method and Description |
---|---|
void |
BaseRegionServerObserver.postReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells) |
void |
RegionServerObserver.postReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells)
This will be called after executing replication request to shipping log entries.
|
void |
BaseRegionServerObserver.preReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells) |
void |
RegionServerObserver.preReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells)
This will be called before executing replication request to shipping log entries.
|
Modifier and Type | Method and Description |
---|---|
AdminProtos.WALEntry |
AdminProtos.WALEntry.Builder.build() |
AdminProtos.WALEntry |
AdminProtos.WALEntry.Builder.buildPartial() |
static AdminProtos.WALEntry |
AdminProtos.WALEntry.getDefaultInstance() |
AdminProtos.WALEntry |
AdminProtos.WALEntry.getDefaultInstanceForType() |
AdminProtos.WALEntry |
AdminProtos.WALEntry.Builder.getDefaultInstanceForType() |
AdminProtos.WALEntry |
AdminProtos.ReplicateWALEntryRequestOrBuilder.getEntry(int index)
repeated .hbase.pb.WALEntry entry = 1; |
AdminProtos.WALEntry |
AdminProtos.ReplicateWALEntryRequest.getEntry(int index)
repeated .hbase.pb.WALEntry entry = 1; |
AdminProtos.WALEntry |
AdminProtos.ReplicateWALEntryRequest.Builder.getEntry(int index)
repeated .hbase.pb.WALEntry entry = 1; |
static AdminProtos.WALEntry |
AdminProtos.WALEntry.parseDelimitedFrom(java.io.InputStream input) |
static AdminProtos.WALEntry |
AdminProtos.WALEntry.parseDelimitedFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AdminProtos.WALEntry |
AdminProtos.WALEntry.parseFrom(byte[] data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AdminProtos.WALEntry |
AdminProtos.WALEntry.parseFrom(com.google.protobuf.ByteString data) |
static AdminProtos.WALEntry |
AdminProtos.WALEntry.parseFrom(com.google.protobuf.ByteString data,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AdminProtos.WALEntry |
AdminProtos.WALEntry.parseFrom(com.google.protobuf.CodedInputStream input) |
static AdminProtos.WALEntry |
AdminProtos.WALEntry.parseFrom(com.google.protobuf.CodedInputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
static AdminProtos.WALEntry |
AdminProtos.WALEntry.parseFrom(java.io.InputStream input,
com.google.protobuf.ExtensionRegistryLite extensionRegistry) |
Modifier and Type | Method and Description |
---|---|
java.util.List<AdminProtos.WALEntry> |
AdminProtos.ReplicateWALEntryRequestOrBuilder.getEntryList()
repeated .hbase.pb.WALEntry entry = 1; |
java.util.List<AdminProtos.WALEntry> |
AdminProtos.ReplicateWALEntryRequest.getEntryList()
repeated .hbase.pb.WALEntry entry = 1; |
java.util.List<AdminProtos.WALEntry> |
AdminProtos.ReplicateWALEntryRequest.Builder.getEntryList()
repeated .hbase.pb.WALEntry entry = 1; |
Modifier and Type | Method and Description |
---|---|
AdminProtos.ReplicateWALEntryRequest.Builder |
AdminProtos.ReplicateWALEntryRequest.Builder.addEntry(AdminProtos.WALEntry value)
repeated .hbase.pb.WALEntry entry = 1; |
AdminProtos.ReplicateWALEntryRequest.Builder |
AdminProtos.ReplicateWALEntryRequest.Builder.addEntry(int index,
AdminProtos.WALEntry value)
repeated .hbase.pb.WALEntry entry = 1; |
static AdminProtos.WALEntry.Builder |
AdminProtos.WALEntry.newBuilder(AdminProtos.WALEntry prototype) |
AdminProtos.ReplicateWALEntryRequest.Builder |
AdminProtos.ReplicateWALEntryRequest.Builder.setEntry(int index,
AdminProtos.WALEntry value)
repeated .hbase.pb.WALEntry entry = 1; |
Modifier and Type | Method and Description |
---|---|
AdminProtos.ReplicateWALEntryRequest.Builder |
AdminProtos.ReplicateWALEntryRequest.Builder.addAllEntry(java.lang.Iterable<? extends AdminProtos.WALEntry> values)
repeated .hbase.pb.WALEntry entry = 1; |
Modifier and Type | Method and Description |
---|---|
void |
RegionServerCoprocessorHost.postReplicateLogEntries(java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells) |
void |
RegionServerCoprocessorHost.preReplicateLogEntries(java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells) |
void |
ReplicationSinkService.replicateLogEntries(java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells,
java.lang.String replicationClusterId,
java.lang.String sourceBaseNamespaceDirPath,
java.lang.String sourceHFileArchiveDirPath)
Carry on the list of log entries down to the sink
|
Modifier and Type | Method and Description |
---|---|
void |
ReplicationSink.replicateEntries(java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells,
java.lang.String replicationClusterId,
java.lang.String sourceBaseNamespaceDirPath,
java.lang.String sourceHFileArchiveDirPath)
Replicate this array of entries directly into the local cluster using the native client.
|
void |
Replication.replicateLogEntries(java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells,
java.lang.String replicationClusterId,
java.lang.String sourceBaseNamespaceDirPath,
java.lang.String sourceHFileArchiveDirPath)
Carry on the list of log entries down to the sink
|
Modifier and Type | Method and Description |
---|---|
void |
AccessController.postReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells) |
void |
AccessController.preReplicateLogEntries(ObserverContext<RegionServerCoprocessorEnvironment> ctx,
java.util.List<AdminProtos.WALEntry> entries,
CellScanner cells) |
Modifier and Type | Method and Description |
---|---|
static java.util.List<WALSplitter.MutationReplay> |
WALSplitter.getMutationsFromWALEntry(AdminProtos.WALEntry entry,
CellScanner cells,
Pair<WALKey,WALEdit> logEntry,
Durability durability)
This function is used to construct mutations from a WALEntry.
|