org.apache.drill.exec.rpc

Class BaseRpcOutcomeListener<T>

java.lang.Object

org.apache.drill.exec.rpc.BaseRpcOutcomeListener<T>

All Implemented Interfaces:

RpcOutcomeListener<T>

Direct Known Subclasses:

EndpointListener

public class BaseRpcOutcomeListener<T>
extends Object
implements RpcOutcomeListener<T>

Constructor Summary

Constructors

Constructor and Description
BaseRpcOutcomeListener()

Method Summary

Modifier and Type	Method and Description
void	failed(RpcException ex) Called when an error occurred while waiting for the RPC outcome.
void	interrupted(InterruptedException ex) Called when the sending thread is interrupted.
void	success(T value, io.netty.buffer.ByteBuf buffer)

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseRpcOutcomeListener

public BaseRpcOutcomeListener()

Method Detail

failed

public void failed(RpcException ex)

Description copied from interface: RpcOutcomeListener

Called when an error occurred while waiting for the RPC outcome.

Specified by:

failed in interface RpcOutcomeListener<T>

success

public void success(T value,
                    io.netty.buffer.ByteBuf buffer)

Specified by:

success in interface RpcOutcomeListener<T>

interrupted

public void interrupted(InterruptedException ex)

Called when the sending thread is interrupted. Possible when the fragment is cancelled due to query cancellations or failures.

Specified by:

interrupted in interface RpcOutcomeListener<T>