org.apache.hadoop.hbase.replication.regionserver

Class RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable

java.lang.Object

org.apache.hadoop.hbase.client.RegionAdminServiceCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>

org.apache.hadoop.hbase.replication.regionserver.RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable

All Implemented Interfaces:

RetryingCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>

Enclosing class:

RegionReplicaReplicationEndpoint

static class RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable
extends RegionAdminServiceCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>

Calls replay on the passed edits for the given set of entries belonging to the region. It skips the entry if the region boundaries have changed or the region is gone.

Field Summary

Fields

Modifier and Type	Field and Description
private List<WAL.Entry>	entries
private byte[]	initialEncodedRegionName
private AtomicLong	skippedEntries

Fields inherited from class org.apache.hadoop.hbase.client.RegionAdminServiceCallable

connection, location, replicaId, row, rpcControllerFactory, stub, tableName

Constructor Summary

Constructors

Constructor and Description
RegionReplicaReplayCallable(ClusterConnection connection, RpcControllerFactory rpcControllerFactory, TableName tableName, HRegionLocation location, RegionInfo regionInfo, byte[] row, List<WAL.Entry> entries, AtomicLong skippedEntries)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse	call(HBaseRpcController controller) Run RPC call.

Methods inherited from class org.apache.hadoop.hbase.client.RegionAdminServiceCallable

call, getExceptionMessage, getExceptionMessageAdditionalDetail, getLocation, getRegionLocations, prepare, setStub, sleep, throwable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

entries

private final List<WAL.Entry> entries

initialEncodedRegionName

private final byte[] initialEncodedRegionName

skippedEntries

private final AtomicLong skippedEntries

Constructor Detail

RegionReplicaReplayCallable

public RegionReplicaReplayCallable(ClusterConnection connection,
                                   RpcControllerFactory rpcControllerFactory,
                                   TableName tableName,
                                   HRegionLocation location,
                                   RegionInfo regionInfo,
                                   byte[] row,
                                   List<WAL.Entry> entries,
                                   AtomicLong skippedEntries)

Method Detail

call

public org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse call(HBaseRpcController controller)
                                                                                             throws Exception

Description copied from class: RegionAdminServiceCallable

Run RPC call.

Specified by:

call in class RegionAdminServiceCallable<org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>

Parameters:

controller - PayloadCarryingRpcController is a mouthful but it at a minimum is a facade on protobuf so we don't have to put protobuf everywhere; we can keep it behind this class.

Throws:

Exception