Package 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	Description
private final List<WAL.Entry>	entries
private final byte[]	initialEncodedRegionName
private final AtomicLong	skippedEntries

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

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

Constructor Summary

Constructors

Constructor	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	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 Details

entries

private final List<WAL.Entry> entries

initialEncodedRegionName

private final byte[] initialEncodedRegionName

skippedEntries

private final AtomicLong skippedEntries

Constructor Details

RegionReplicaReplayCallable

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

Method Details

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