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
-
Method Summary
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
-
Constructor Details
-
ConnectionListeningFuture
-
-
Method Details
-
waitAndRun
public void waitAndRun()Called by -
connectionFailed
- Specified by:
connectionFailed
in interfaceRpcConnectionHandler<R extends com.google.protobuf.MessageLite>
-
connectionSucceeded
- Specified by:
connectionSucceeded
in interfaceRpcConnectionHandler<R extends com.google.protobuf.MessageLite>
-