BarrierTakeMany.Options

public static class BarrierTakeMany.Options

Optional attributes for BarrierTakeMany

Public Methods

BarrierTakeMany.Options	allowSmallBatch(Boolean allowSmallBatch)
BarrierTakeMany.Options	timeoutMs(Long timeoutMs)
BarrierTakeMany.Options	waitForIncomplete(Boolean waitForIncomplete)

Inherited Methods

From class java.lang.Object

boolean	equals(Object arg0)
final Class<?>	getClass()
int	hashCode()
final void	notify()
final void	notifyAll()
String	toString()
final void	wait(long arg0, int arg1)
final void	wait(long arg0)
final void	wait()

Public Methods

public BarrierTakeMany.Options allowSmallBatch (Boolean allowSmallBatch)

Parameters

allowSmallBatch	Allow to return less than num_elements items if barrier is already closed.

public BarrierTakeMany.Options timeoutMs (Long timeoutMs)

Parameters

timeoutMs	If the queue is empty, this operation will block for up to timeout_ms milliseconds. Note: This option is not supported yet.

public BarrierTakeMany.Options waitForIncomplete (Boolean waitForIncomplete)