Package org.apache.druid.frame.processor

Class RunAllFullyWidget<T,ResultType>

java.lang.Object
org.apache.druid.frame.processor.RunAllFullyWidget<T,ResultType>
public class RunAllFullyWidget<T,ResultType> extends Object
Helper for FrameProcessorExecutor.runAllFully(org.apache.druid.frame.processor.manager.ProcessorManager<T, ? extends R>, int, org.apache.druid.frame.processor.Bouncer, java.lang.String). See the javadoc for that method for details about the expected behavior of this class. One instance of this class is created for each call to FrameProcessorExecutor.runAllFully(org.apache.druid.frame.processor.manager.ProcessorManager<T, ? extends R>, int, org.apache.druid.frame.processor.Bouncer, java.lang.String). It gradually executes all processors from the provided sequence using the FrameProcessorExecutor.runFully(org.apache.druid.frame.processor.FrameProcessor<T>, java.lang.String) method. The bouncer and maxOutstandingProcessors parameters are used to control how many processors are executed on the FrameProcessorExecutor concurrently.