Package org.apache.drill.exec.rpc

Class FutureBitCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

java.lang.Object

org.apache.drill.exec.rpc.FutureBitCommand<T,C,E,M>

All Implemented Interfaces:

RpcCommand<T,C,E,M>, RpcConnectionHandler<C>

Direct Known Subclasses:

ControlTunnel.CancelQuery, ControlTunnel.RequestProfile, ControlTunnel.SendFragmentStatus, ControlTunnel.SyncCustomMessageSender

public abstract class FutureBitCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>
extends Object
implements RpcCommand<T,C,E,M>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.drill.exec.rpc.RpcConnectionHandler

RpcConnectionHandler.FailureType

Field Summary

Fields

Modifier and Type	Field	Description
protected final com.google.common.util.concurrent.SettableFuture<T>	settableFuture

Constructor Summary

Constructors

Constructor	Description
FutureBitCommand()

Method Summary

Modifier and Type	Method	Description
void	connectionAvailable(C connection)
void	connectionFailed(RpcConnectionHandler.FailureType type, Throwable t)
void	connectionSucceeded(C connection)
abstract void	doRpcCall(RpcOutcomeListener<T> outcomeListener, C connection)
DrillRpcFuture<T>	getFuture()
RpcOutcomeListener<T>	getOutcomeListener()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.exec.rpc.RpcCommand

getMessage, getRpcType

Field Details

settableFuture

protected final com.google.common.util.concurrent.SettableFuture<T extends com.google.protobuf.MessageLite> settableFuture

Constructor Details

FutureBitCommand

public FutureBitCommand()

Method Details

doRpcCall

public abstract void doRpcCall(RpcOutcomeListener<T> outcomeListener,
 C connection)

connectionAvailable

public void connectionAvailable(C connection)

Specified by:

connectionAvailable in interface RpcCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

connectionSucceeded

public void connectionSucceeded(C connection)

Specified by:

connectionSucceeded in interface RpcConnectionHandler<T extends com.google.protobuf.MessageLite>

getFuture

public DrillRpcFuture<T> getFuture()

getOutcomeListener

public RpcOutcomeListener<T> getOutcomeListener()

Specified by:

getOutcomeListener in interface RpcCommand<T extends com.google.protobuf.MessageLite,C extends RemoteConnection,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

connectionFailed

public void connectionFailed(RpcConnectionHandler.FailureType type,
 Throwable t)

Specified by:

connectionFailed in interface RpcConnectionHandler<T extends com.google.protobuf.MessageLite>