Package org.apache.drill.exec.rpc

Interface RpcOutcomeListener<V>

All Known Implementing Classes:
AuthenticationOutcomeListener, BaseRpcOutcomeListener, DataTunnelStatusHandler, EndpointListener, StatusHandler
public interface RpcOutcomeListener<V>

  • Method Summary

    Modifier and Type
    Method
    Description
    default 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(V value, io.netty.buffer.ByteBuf buffer)
     

  • Method Details

    • failed

      void failed(RpcException ex)
      Called when an error occurred while waiting for the RPC outcome.
      Parameters:
      ex -

    • success

      void success(V value, io.netty.buffer.ByteBuf buffer)

    • interrupted

      void interrupted(InterruptedException e)
      Called when the sending thread is interrupted. Possible when the fragment is cancelled due to query cancellations or failures.

    • complete

      default void complete()
      Called when an operator complete for waiting msg release