RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.client.RegionAdminServiceCallable<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>
- - org.apache.hadoop.hbase.replication.regionserver.RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable

All Implemented Interfaces:

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

Enclosing class:

RegionReplicaReplicationEndpoint
```
static class RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable
extends RegionAdminServiceCallable<org.apache.hadoop.hbase.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

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

Constructor Summary

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

Method Summary

Methods
Modifier and Type	Method and Description
`org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse`	`call(int timeout)` Computes a result, or throws an exception if unable to do so.
`private org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse`	`replayToServer(List<WAL.Entry> entries, int timeout)`

Methods inherited from class org.apache.hadoop.hbase.client.RegionAdminServiceCallable
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

RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable

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

Method Detail

call
```
public org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse call(int timeout)
                                                                                      throws IOException
```
Description copied from interface: RetryingCallable

Computes a result, or throws an exception if unable to do so.

Parameters:
timeout - - the time available for this call. 0 for infinite.

Returns:
computed result

Throws:

IOException

replayToServer

private org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse replayToServer(List<WAL.Entry> entries,
                                                                                              int timeout)
                                                                                                 throws IOException

Throws:: IOException

Class RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Field Detail

entries

initialEncodedRegionName

skippedEntries

Constructor Detail

RegionReplicaReplicationEndpoint.RegionReplicaReplayCallable

Method Detail

call

replayToServer