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

Class ProcessorAndCallback<T>

java.lang.Object

org.apache.druid.frame.processor.manager.ProcessorAndCallback<T>

public class ProcessorAndCallback<T>
extends Object

Processor and success callback returned by ProcessorManager.next().

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
void	onComplete(T resultObject)
FrameProcessor<T>	processor()

Methods inherited from class java.lang.Object

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

Constructor Details

ProcessorAndCallback

public ProcessorAndCallback(FrameProcessor<T> processor,
 @Nullable
 Consumer<T> callback)

Method Details

processor

public FrameProcessor<T> processor()

onComplete

public void onComplete(T resultObject)