Package org.apache.drill.exec.rpc.control

Class ControlTunnel.CustomFuture<RECEIVE>

java.lang.Object

org.apache.drill.exec.rpc.control.ControlTunnel.CustomFuture<RECEIVE>

Type Parameters:

RECEIVE - The type of message that will be returned.

Enclosing class:

ControlTunnel

public class ControlTunnel.CustomFuture<RECEIVE>
extends Object

A class used to return a synchronous future when doing custom rpc messages.

Constructor Summary

Constructors

Constructor	Description
CustomFuture(Controller.CustomSerDe<RECEIVE> serde, DrillRpcFuture<BitControl.CustomMessage> future)

Method Summary

Modifier and Type	Method	Description
RECEIVE	get()
RECEIVE	get(long timeout, TimeUnit unit)
DrillBuf	getBuffer()

Methods inherited from class java.lang.Object

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

Constructor Details

CustomFuture

public CustomFuture(Controller.CustomSerDe<RECEIVE> serde,
 DrillRpcFuture<BitControl.CustomMessage> future)

Method Details

get

public RECEIVE get()
            throws Exception

Throws:

Exception

get

public RECEIVE get(long timeout,
 TimeUnit unit)
            throws Exception,
com.google.protobuf.InvalidProtocolBufferException

Throws:

Exception

com.google.protobuf.InvalidProtocolBufferException

getBuffer

public DrillBuf getBuffer()
                   throws RpcException

Throws:

RpcException