Package org.apache.drill.exec.ops

Class DataTunnelStatusHandler

java.lang.Object

org.apache.drill.exec.ops.DataTunnelStatusHandler

All Implemented Interfaces:

RpcOutcomeListener<BitData.AckWithCredit>

public class DataTunnelStatusHandler
extends Object
implements RpcOutcomeListener<BitData.AckWithCredit>

Listener that keeps track of the status of batches sent, and updates the SendingAccountor when status is received for each batch

Constructor Summary

Constructors

Constructor	Description
DataTunnelStatusHandler(Consumer<RpcException> consumer, SendingAccountor sendingAccountor)

Method Summary

Modifier and Type	Method	Description
void	complete()	Called when an operator complete for waiting msg release
void	failed(RpcException ex)	Called when an error occurred while waiting for the RPC outcome.
void	interrupted(InterruptedException e)	Called when the sending thread is interrupted.
void	success(BitData.AckWithCredit 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 Details

DataTunnelStatusHandler

public DataTunnelStatusHandler(Consumer<RpcException> consumer,
 SendingAccountor sendingAccountor)

Method Details

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<BitData.AckWithCredit>

Parameters:

ex -

success

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

Specified by:

success in interface RpcOutcomeListener<BitData.AckWithCredit>

interrupted

public void interrupted(InterruptedException e)

Description copied from interface: RpcOutcomeListener

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<BitData.AckWithCredit>

complete

public void complete()

Description copied from interface: RpcOutcomeListener

Called when an operator complete for waiting msg release

Specified by:

complete in interface RpcOutcomeListener<BitData.AckWithCredit>