Package org.apache.drill.exec.rpc.data

Class AckSender

java.lang.Object

org.apache.drill.exec.rpc.data.AckSender

public class AckSender
extends Object

Utility class that allows a group of receivers to confirm reception of a record batch as a single unit. Response isn't send upstream until all receivers have successfully consumed data.

Constructor Summary

Constructors

Constructor	Description
AckSender(ResponseSender sender)

Method Summary

Modifier and Type	Method	Description
void	sendFail()
void	sendOk()	Decrement the number of references still holding on to this response.
void	sendOk(int credit)	Decrement the number of references still holding on to this response.

Methods inherited from class java.lang.Object

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

Constructor Details

AckSender

public AckSender(ResponseSender sender)

Method Details

sendOk

public void sendOk()

Decrement the number of references still holding on to this response. When the number of references hit zero, send response upstream.

sendOk

public void sendOk(int credit)

Decrement the number of references still holding on to this response. When the number of references hit zero, send response upstream. Ack for the dynamic credit model credit == -1 means Fail

Parameters:

credit - suggested credit value

sendFail

public void sendFail()