org.apache.hadoop.hbase.replication.regionserver

Class ClaimReplicationQueueCallable

java.lang.Object

org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable

org.apache.hadoop.hbase.replication.regionserver.ClaimReplicationQueueCallable

All Implemented Interfaces:

Callable<Void>, RSProcedureCallable

@InterfaceAudience.Private
public class ClaimReplicationQueueCallable
extends BaseRSProcedureCallable

Field Summary

Fields

Modifier and Type	Field and Description
private ServerName	crashedServer
private String	queue

Fields inherited from class org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable

rs

Constructor Summary

Constructors

Constructor and Description
ClaimReplicationQueueCallable()

Method Summary

Modifier and Type	Method and Description
protected void	doCall()
EventType	getEventType() Event type used to select thread pool.
protected void	initParameter(byte[] parameter)

Methods inherited from class org.apache.hadoop.hbase.procedure2.BaseRSProcedureCallable

call, init

Methods inherited from class java.lang.Object

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

Field Detail

crashedServer

private ServerName crashedServer

queue

private String queue

Constructor Detail

ClaimReplicationQueueCallable

public ClaimReplicationQueueCallable()

Method Detail

getEventType

public EventType getEventType()

Description copied from interface: RSProcedureCallable

Event type used to select thread pool.

doCall

protected void doCall()
               throws Exception

Specified by:

doCall in class BaseRSProcedureCallable

Throws:

Exception

initParameter

protected void initParameter(byte[] parameter)
                      throws org.apache.hbase.thirdparty.com.google.protobuf.InvalidProtocolBufferException

Specified by:

initParameter in class BaseRSProcedureCallable

Throws:

org.apache.hbase.thirdparty.com.google.protobuf.InvalidProtocolBufferException