Uses of Interface
org.apache.druid.frame.processor.manager.ProcessorManager

Packages that use ProcessorManager

Package	Description
org.apache.druid.frame.processor
org.apache.druid.frame.processor.manager

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

Methods in org.apache.druid.frame.processor with parameters of type ProcessorManager

Modifier and Type	Method	Description
<T, R> com.google.common.util.concurrent.ListenableFuture<R>	FrameProcessorExecutor.runAllFully(ProcessorManager<T,R> processorManager, int maxOutstandingProcessors, Bouncer bouncer, String cancellationId)	Runs a sequence of processors and returns a future that resolves when execution is complete.

Uses of ProcessorManager in org.apache.druid.frame.processor.manager

Classes in org.apache.druid.frame.processor.manager that implement ProcessorManager

Modifier and Type	Class	Description
class	AccumulatingProcessorManager<T,R>	Processor manager that wraps another ProcessorManager and accumulates a result.
class	ConcurrencyLimitedProcessorManager<T,R>	Manager that limits the number of processors that may run concurrently.
class	SequenceProcessorManager<T,P extends FrameProcessor<T>>	Processor manager based on a Sequence.

Methods in org.apache.druid.frame.processor.manager that return ProcessorManager

Modifier and Type	Method	Description
static <T> ProcessorManager<T,Long>	ProcessorManagers.none()	Manager with zero processors.
static <T> ProcessorManager<T,Long>	ProcessorManagers.of(Iterable<? extends FrameProcessor<T>> processors)	Manager with processors derived from an Iterable.
static <T> ProcessorManager<T,Long>	ProcessorManagers.of(Supplier<? extends FrameProcessor<T>> processors)	Manager with a single processor derived from a Supplier.
static <T> ProcessorManager<T,Long>	ProcessorManagers.of(Sequence<? extends FrameProcessor<T>> processors)	Manager with processors derived from a Sequence.
default <R2> ProcessorManager<T,R2>	ProcessorManager.withAccumulation(R2 initialResult, BiFunction<R2,T,R2> accumulateFn)	Returns an AccumulatingProcessorManager that wraps this manager and accumulates a result, to be returned by its result() method.

Constructors in org.apache.druid.frame.processor.manager with parameters of type ProcessorManager

Modifier	Constructor	Description
	AccumulatingProcessorManager(ProcessorManager<T,?> delegate, R initialResult, BiFunction<R,T,R> accumulateFn)
	ConcurrencyLimitedProcessorManager(ProcessorManager<T,R> delegate, int limit)