Uses of Class
org.apache.druid.frame.processor.ReturnOrAwait

Packages that use ReturnOrAwait

Package	Description
org.apache.druid.frame.processor

Uses of ReturnOrAwait in org.apache.druid.frame.processor

Methods in org.apache.druid.frame.processor that return ReturnOrAwait

Modifier and Type	Method	Description
static <T> ReturnOrAwait<T>	ReturnOrAwait.awaitAll(int count)	Wait for all of a certain number of channels.
static <T> ReturnOrAwait<T>	ReturnOrAwait.awaitAll(it.unimi.dsi.fastutil.ints.IntSet await)	Wait for all provided channels to become readable (or finished).
static <T> ReturnOrAwait<T>	ReturnOrAwait.awaitAllFutures(Collection<com.google.common.util.concurrent.ListenableFuture<?>> futures)	Wait for all of the provided futures.
static <T> ReturnOrAwait<T>	ReturnOrAwait.awaitAny(it.unimi.dsi.fastutil.ints.IntSet await)	Wait for any of the provided channels to become readable (or finished).
static <T> ReturnOrAwait<T>	ReturnOrAwait.returnObject(T o)	Return a result.
static <T> ReturnOrAwait<T>	ReturnOrAwait.runAgain()	Wait for nothing; that is: run again as soon as possible.
ReturnOrAwait<Pair<List<Frame>,it.unimi.dsi.fastutil.ints.IntSet>>	FrameChannelBatcher.runIncrementally(it.unimi.dsi.fastutil.ints.IntSet readableInputs)
ReturnOrAwait<Long>	FrameChannelHashPartitioner.runIncrementally(it.unimi.dsi.fastutil.ints.IntSet readableInputs)
ReturnOrAwait<Long>	FrameChannelMerger.runIncrementally(it.unimi.dsi.fastutil.ints.IntSet readableInputs)
ReturnOrAwait<Long>	FrameChannelMixer.runIncrementally(it.unimi.dsi.fastutil.ints.IntSet readableInputs)
ReturnOrAwait<T>	FrameProcessor.runIncrementally(it.unimi.dsi.fastutil.ints.IntSet readableInputs)	Runs some of the algorithm, without blocking, and either returns a value or a set of input channels to wait for.
ReturnOrAwait<Void>	RunnableFrameProcessor.runIncrementally(it.unimi.dsi.fastutil.ints.IntSet readableInputs)