public static class BarrierTakeMany.Options extends Object
BarrierTakeMany
Modifier and Type | Method and Description |
---|---|
BarrierTakeMany.Options |
allowSmallBatch(Boolean allowSmallBatch) |
BarrierTakeMany.Options |
timeoutMs(Long timeoutMs) |
BarrierTakeMany.Options |
waitForIncomplete(Boolean waitForIncomplete) |
public BarrierTakeMany.Options allowSmallBatch(Boolean allowSmallBatch)
allowSmallBatch
- Allow to return less than num_elements items if barrier is
already closed.public BarrierTakeMany.Options waitForIncomplete(Boolean waitForIncomplete)
waitForIncomplete
- public BarrierTakeMany.Options timeoutMs(Long timeoutMs)
timeoutMs
- If the queue is empty, this operation will block for up to
timeout_ms milliseconds.
Note: This option is not supported yet.Copyright © 2022. All rights reserved.