com.lucidworks.apollo.pipeline.index

Class SimpleIndexStage<C extends StageConfig>

java.lang.Object

com.lucidworks.apollo.pipeline.AbstractStage<M,C>

com.lucidworks.apollo.pipeline.AbstractProcessor<PipelineDocument,C>

com.lucidworks.apollo.pipeline.index.IndexStage<C>

com.lucidworks.apollo.pipeline.index.SimpleIndexStage<C>

All Implemented Interfaces:

Configurable<C>, Processor<PipelineDocument>, Stage<PipelineDocument,C>

public abstract class SimpleIndexStage<C extends StageConfig>
extends IndexStage<C>

Field Summary

Fields inherited from class com.lucidworks.apollo.pipeline.AbstractStage

NOW_KEY

Method Summary

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)

Methods inherited from class com.lucidworks.apollo.pipeline.index.IndexStage

getMessageClass

Methods inherited from class com.lucidworks.apollo.pipeline.AbstractStage

getConfiguration, getConfigurationComponent, getContextFactory, getId, getMetricRegistry, handleSignal, init, managedModeEnabled

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.lucidworks.apollo.pipeline.Processor

handleSignal

Methods inherited from interface com.lucidworks.apollo.pipeline.Configurable

getStageConfigClass

Method Detail

process

public abstract PipelineDocument process(PipelineDocument message,
                                         Context context)
                                  throws java.lang.Exception

Throws:

java.lang.Exception

process

public final void process(PipelineDocument message,
                          Context context,
                          StageOutput<PipelineDocument> output)
                   throws java.lang.Exception

Description copied from class: AbstractStage

Implements the default behavior for a stage when it receives a message (which is to simply pass it to the next stage)

Specified by:

process in interface Processor<PipelineDocument>

Overrides:

process in class AbstractStage<PipelineDocument,C extends StageConfig>

Throws:

java.lang.Exception