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

Class ProcessorManagers

java.lang.Object

org.apache.druid.frame.processor.manager.ProcessorManagers

public class ProcessorManagers
extends Object

Utility functions for creating ProcessorManager.

Method Summary

Modifier and Type	Method	Description
static <T> ProcessorManager<T,Long>	none()	Manager with zero processors.
static <T> ProcessorManager<T,Long>	of(Iterable<? extends FrameProcessor<T>> processors)	Manager with processors derived from an Iterable.
static <T> ProcessorManager<T,Long>	of(Supplier<? extends FrameProcessor<T>> processors)	Manager with a single processor derived from a Supplier.
static <T> ProcessorManager<T,Long>	of(Sequence<? extends FrameProcessor<T>> processors)	Manager with processors derived from a Sequence.

Methods inherited from class java.lang.Object

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

Method Details

none

public static <T> ProcessorManager<T,Long> none()

Manager with zero processors. Returns the number of processors run.

of

public static <T> ProcessorManager<T,Long> of(Sequence<? extends FrameProcessor<T>> processors)

Manager with processors derived from a Sequence. Returns the number of processors run.

of

public static <T> ProcessorManager<T,Long> of(Iterable<? extends FrameProcessor<T>> processors)

Manager with processors derived from an Iterable. Returns the number of processors run.

of

public static <T> ProcessorManager<T,Long> of(Supplier<? extends FrameProcessor<T>> processors)

Manager with a single processor derived from a Supplier. Returns the number of processors run.