com.lucidworks.apollo.pipeline

Class AbstractGenerator<M,C extends StageConfig>

java.lang.Object

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

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

All Implemented Interfaces:

Configurable<C>, Generator<M,C>, Lifecycle, Processor<M>, Stage<M,C>, StageOutput<M>

Direct Known Subclasses:

DocumentGenerator

public abstract class AbstractGenerator<M,C extends StageConfig>
extends AbstractStage<M,C>
implements Generator<M,C>

Method Summary

Modifier and Type	Method and Description
void	onFinished(java.lang.Runnable finishedRunnable)
void	send(M message, Context context)
void	setStageOutput(StageOutput<M> stageOutput)

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

getConfiguration, getContextFactory, getId, getMetricRegistry, handleSignal, init, process

Methods inherited from class java.lang.Object

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

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

getContextFactory, getId, getMessageClass, getMetricRegistry

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

handleSignal, process

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

getConfiguration, getStageConfigClass, init

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

start, stop

Method Detail

setStageOutput

public void setStageOutput(StageOutput<M> stageOutput)

onFinished

public void onFinished(java.lang.Runnable finishedRunnable)

Specified by:

onFinished in interface Generator<M,C extends StageConfig>

send

public void send(M message,
                 Context context)

Specified by:

send in interface StageOutput<M>