org.apache.hadoop.hbase.client

Class AsyncRequestFutureImpl.SingleServerRequestRunnable

java.lang.Object

org.apache.hadoop.hbase.client.AsyncRequestFutureImpl.SingleServerRequestRunnable

All Implemented Interfaces:

Runnable

Enclosing class:

AsyncRequestFutureImpl<CResult>

final class AsyncRequestFutureImpl.SingleServerRequestRunnable
extends Object
implements Runnable

Runnable (that can be submitted to thread pool) that submits MultiAction to a single server. The server call is synchronous, therefore we do it on a thread pool.

Field Summary

Fields

Modifier and Type	Field and Description
private Set<CancellableRegionServerCallable>	callsInProgress
private MultiAction	multiAction
private int	numAttempt
private ServerName	server

Constructor Summary

Constructors

Constructor and Description
SingleServerRequestRunnable(MultiAction multiAction, int numAttempt, ServerName server, Set<CancellableRegionServerCallable> callsInProgress)

Method Summary

Modifier and Type	Method and Description
void	run()

Methods inherited from class java.lang.Object

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

Field Detail

multiAction

private final MultiAction multiAction

numAttempt

private final int numAttempt

server

private final ServerName server

callsInProgress

private final Set<CancellableRegionServerCallable> callsInProgress

Constructor Detail

SingleServerRequestRunnable

SingleServerRequestRunnable(MultiAction multiAction,
                            int numAttempt,
                            ServerName server,
                            Set<CancellableRegionServerCallable> callsInProgress)

Method Detail

run

public void run()

Specified by:

run in interface Runnable