public abstract class SimpleIndexStage<C extends StageConfig> extends IndexStage<C>
CONTEXT_TEMPLATE_KEY, DOC_TEMPLATE_KEY
Modifier and Type | Method and Description |
---|---|
abstract PipelineDocument |
process(PipelineDocument message,
Context context) |
void |
process(PipelineDocument message,
Context context,
StageOutput<PipelineDocument> output)
Implements the default behavior for a stage when it receives a message (which is to simply pass it to the next stage)
|
getMessageClass
getConfiguration, getContextFactory, getId, getMetricRegistry, handleSignal, init
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handleSignal
getStageConfigClass
public abstract PipelineDocument process(PipelineDocument message, Context context) throws java.lang.Exception
java.lang.Exception
public final void process(PipelineDocument message, Context context, StageOutput<PipelineDocument> output) throws java.lang.Exception
AbstractStage
process
in interface Processor<PipelineDocument>
process
in class AbstractStage<PipelineDocument,C extends StageConfig>
java.lang.Exception