WALEditsReplaySink.ReplayServerCallable (Apache HBase 1.2.12 API)

java.lang.Object
- org.apache.hadoop.hbase.client.RegionServerCallable<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>
- - org.apache.hadoop.hbase.regionserver.wal.WALEditsReplaySink.ReplayServerCallable<R>

Type Parameters:
R -

All Implemented Interfaces:

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

Enclosing class:

WALEditsReplaySink
```
 class WALEditsReplaySink.ReplayServerCallable<R>
extends RegionServerCallable<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>
```
Callable that handles the replay method call going against a single regionserver

Field Summary

Fields
Modifier and Type Field and Description

private List<WAL.Entry> entries

private HRegionInfo regionInfo
- Fields inherited from class org.apache.hadoop.hbase.client.RegionServerCallable
  connection, location, row, tableName

Fields
Modifier and Type	Field and Description
`private List<WAL.Entry>`	`entries`
`private HRegionInfo`	`regionInfo`

Constructor Summary

Constructors
Constructor and Description
`WALEditsReplaySink.ReplayServerCallable(HConnection connection, TableName tableName, HRegionLocation regionLoc, HRegionInfo regionInfo, List<WAL.Entry> entries)`

Method Summary

Methods
Modifier and Type	Method and Description
`org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse`	`call(int callTimeout)` Computes a result, or throws an exception if unable to do so.
`void`	`prepare(boolean reload)` Prepare for connection to the server hosting region with row from tablename.
`private void`	`replayToServer(HRegionInfo regionInfo, List<WAL.Entry> entries)`

Methods inherited from class org.apache.hadoop.hbase.client.RegionServerCallable
getExceptionMessageAdditionalDetail, getHRegionInfo, getLocation, getRow, getStub, getTableName, setLocation, sleep, throwable

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

regionInfo
```
private HRegionInfo regionInfo
```

entries
```
private List<WAL.Entry> entries
```

Constructor Detail

WALEditsReplaySink.ReplayServerCallable

WALEditsReplaySink.ReplayServerCallable(HConnection connection,
                                       TableName tableName,
                                       HRegionLocation regionLoc,
                                       HRegionInfo regionInfo,
                                       List<WAL.Entry> entries)

Method Detail
- call
```
public org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse call(int callTimeout)
                                                                                      throws IOException
```
  Description copied from interface: RetryingCallable
  
  Computes a result, or throws an exception if unable to do so.
  
  Parameters:
  callTimeout - - the time available for this call. 0 for infinite.
  
  Returns:
  computed result
  
  Throws:
  
  IOException
- replayToServer
```
private void replayToServer(HRegionInfo regionInfo,
                  List<WAL.Entry> entries)
                     throws IOException,
                            com.google.protobuf.ServiceException
```
  Throws:
  
  IOException
  
  com.google.protobuf.ServiceException
- prepare
```
public void prepare(boolean reload)
             throws IOException
```
  Description copied from class: RegionServerCallable
  
  Prepare for connection to the server hosting region with row from tablename. Does lookup to find region location and hosting server.
  
  Specified by:
  
  prepare in interface RetryingCallable<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>
  
  Overrides:
  
  prepare in class RegionServerCallable<org.apache.hadoop.hbase.protobuf.generated.AdminProtos.ReplicateWALEntryResponse>
  
  Parameters:
  reload - Set this to true if connection should re-find the region
  
  Throws:
  
  IOException - e

Class WALEditsReplaySink.ReplayServerCallable<R>

Field Summary

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

Constructor Summary

Method Summary

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

Methods inherited from class java.lang.Object

Field Detail

regionInfo

entries

Constructor Detail

WALEditsReplaySink.ReplayServerCallable

Method Detail

call

replayToServer

prepare