Uses of Interface
org.apache.druid.frame.processor.FrameProcessor

Packages that use FrameProcessor

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

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

Classes in org.apache.druid.frame.processor that implement FrameProcessor

Modifier and Type	Class	Description
class	FrameChannelBatcher	Processor that reads up to "maxFrames" frames from some input channels and combines them into a batch.
class	FrameChannelHashPartitioner	Processor that hash-partitions rows from any number of input channels, and writes partitioned frames to output channels.
class	FrameChannelMerger	Processor that merges already-sorted inputChannels and writes a fully-sorted stream to a single outputChannel.
class	FrameChannelMixer	Processor that merges frames from inputChannels into a single outputChannel.
class	RunnableFrameProcessor	Frame processor that simply runs a Runnable, once.

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

Modifier and Type	Method	Description
<T> FrameProcessor<T>	FrameProcessorDecorator.decorate(FrameProcessor<T> processor)
static <T> FrameProcessor<T>	FrameProcessors.withBaggage(FrameProcessor<T> processor, Closeable baggage)

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

Modifier and Type	Method	Description
<T> FrameProcessor<T>	FrameProcessorDecorator.decorate(FrameProcessor<T> processor)
<T> com.google.common.util.concurrent.ListenableFuture<T>	FrameProcessorExecutor.runFully(FrameProcessor<T> processor, String cancellationId)	Runs a processor until it is done, and returns a future that resolves when execution is complete.
static <T> FrameProcessor<T>	FrameProcessors.withBaggage(FrameProcessor<T> processor, Closeable baggage)

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

Classes in org.apache.druid.frame.processor.manager with type parameters of type FrameProcessor

Modifier and Type	Class	Description
class	SequenceProcessorManager<T,P extends FrameProcessor<T>>	Processor manager based on a Sequence.

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

Modifier and Type	Method	Description
FrameProcessor<T>	ProcessorAndCallback.processor()

Method parameters in org.apache.druid.frame.processor.manager with type arguments of type FrameProcessor

Modifier and Type	Method	Description
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.

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

Modifier	Constructor	Description
	ProcessorAndCallback(FrameProcessor<T> processor, Consumer<T> callback)