Package org.apache.drill.exec.rpc

Class ReconnectingConnection.ConnectionListeningFuture<R extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>

java.lang.Object

org.apache.drill.shaded.guava.com.google.common.util.concurrent.internal.InternalFutureFailureAccess

org.apache.drill.shaded.guava.com.google.common.util.concurrent.AbstractFuture<C>

org.apache.drill.exec.rpc.ReconnectingConnection.ConnectionListeningFuture<R,E,M>

All Implemented Interfaces:

Future<C>, RpcConnectionHandler<C>, org.apache.drill.shaded.guava.com.google.common.util.concurrent.ListenableFuture<C>

Enclosing class:

ReconnectingConnection<C extends ClientConnection,HS extends com.google.protobuf.MessageLite>

public class ReconnectingConnection.ConnectionListeningFuture<R extends com.google.protobuf.MessageLite,E extends com.google.protobuf.Internal.EnumLite,M extends com.google.protobuf.MessageLite>
extends org.apache.drill.shaded.guava.com.google.common.util.concurrent.AbstractFuture<C>
implements RpcConnectionHandler<C>

Nested Class Summary

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

RpcConnectionHandler.FailureType

Constructor Summary

Constructors

Constructor	Description
ConnectionListeningFuture(RpcCommand<R,C,E,M> cmd)

Method Summary

Modifier and Type	Method	Description
void	connectionFailed(RpcConnectionHandler.FailureType type, Throwable t)
void	connectionSucceeded(C incoming)
void	waitAndRun()	Called by

Methods inherited from class org.apache.drill.shaded.guava.com.google.common.util.concurrent.AbstractFuture

addListener, afterDone, cancel, get, get, interruptTask, isCancelled, isDone, pendingToString, set, setException, setFuture, toString, tryInternalFastPathGetFailure, wasInterrupted

Methods inherited from class java.lang.Object

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

Constructor Details

ConnectionListeningFuture

public ConnectionListeningFuture(RpcCommand<R,C,E,M> cmd)

Method Details

waitAndRun

public void waitAndRun()

Called by

connectionFailed

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

Specified by:

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

connectionSucceeded

public void connectionSucceeded(C incoming)

Specified by:

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