Package org.apache.drill.exec.work.batch

Class ResponseSenderQueue

java.lang.Object

org.apache.drill.exec.work.batch.ResponseSenderQueue

public class ResponseSenderQueue
extends Object

Constructor Summary

Constructors

Constructor	Description
ResponseSenderQueue()

Method Summary

Modifier and Type	Method	Description
void	enqueueResponse(AckSender sender)
void	flushResponses()
int	flushResponses(int count)	Flush only up to a count responses

Methods inherited from class java.lang.Object

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

Constructor Details

ResponseSenderQueue

public ResponseSenderQueue()

Method Details

enqueueResponse

public void enqueueResponse(AckSender sender)

flushResponses

public void flushResponses()

flushResponses

public int flushResponses(int count)

Flush only up to a count responses

Parameters:

count -

Returns: