Package org.apache.druid.frame.processor

Class AwaitAnyWidget

java.lang.Object

org.apache.druid.frame.processor.AwaitAnyWidget

public class AwaitAnyWidget
extends Object

Helper used by FrameProcessorExecutor.runFully(org.apache.druid.frame.processor.FrameProcessor<T>, java.lang.String) when workers return ReturnOrAwait.awaitAny(it.unimi.dsi.fastutil.ints.IntSet). The main idea is to reuse listeners from previous calls to awaitAny(IntSet) in cases where a particular channel has not receieved any input since the last call. (Otherwise, listeners would pile up.)

Constructor Summary

Constructors

Constructor	Description
AwaitAnyWidget(List<ReadableFrameChannel> channels)

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<?>	awaitAny(it.unimi.dsi.fastutil.ints.IntSet awaitSet)	Returns a future that resolves when any channel in the provided set is ready for reading.

Methods inherited from class java.lang.Object

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

Constructor Details

AwaitAnyWidget

public AwaitAnyWidget(List<ReadableFrameChannel> channels)

Method Details

awaitAny

public com.google.common.util.concurrent.ListenableFuture<?> awaitAny(it.unimi.dsi.fastutil.ints.IntSet awaitSet)

Returns a future that resolves when any channel in the provided set is ready for reading. Numbers in this set correspond to positions in the channels list.