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

package org.apache.druid.frame.processor.manager

Related Packages

Package	Description
org.apache.druid.frame.processor

Class	Description
AccumulatingProcessorManager<T,R>	Processor manager that wraps another ProcessorManager and accumulates a result.
ConcurrencyLimitedProcessorManager<T,R>	Manager that limits the number of processors that may run concurrently.
ProcessorAndCallback<T>	Processor and success callback returned by ProcessorManager.next().
ProcessorManager<T,R>	Used by FrameProcessorExecutor.runAllFully(org.apache.druid.frame.processor.manager.ProcessorManager<T, R>, int, org.apache.druid.frame.processor.Bouncer, java.lang.String) to manage the launching of processors.
ProcessorManagers	Utility functions for creating ProcessorManager.
SequenceProcessorManager<T,P extends FrameProcessor<T>>	Processor manager based on a Sequence.