Package com.lucidworks.apollo.pipeline

Class AbstractGenerator<M,C extends com.lucidworks.apollo.pipeline.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>

public abstract class AbstractGenerator<M,C extends com.lucidworks.apollo.pipeline.StageConfig>
extends AbstractStage<M,C>
implements Generator<M,C>

Field Summary

Fields

Modifier and Type	Field	Description
protected Runnable	finishedRunnable

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

NOW_KEY, paramsInited

Constructor Summary

Constructors

Constructor	Description
AbstractGenerator()

Method Summary

Modifier and Type	Method	Description
protected void	finish()
void	onFinished(Runnable finishedRunnable)
void	send(M message, com.lucidworks.apollo.pipeline.Context context)
void	setStageOutput(StageOutput<M> stageOutput)

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

escapeKey, getConditionScriptFuncArguments, getConditionScriptFuncWrapper, getConfiguration, getConfigurationComponent, getContextFactory, getId, getMetricRegistry, getProperty, handleSignal, init, managedModeEnabled, preInit, process

Methods inherited from class java.lang.Object

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

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

getConfiguration, getProperty, init

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

start, stop

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

handleSignal, process

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

getContextFactory, getId, getMessageClass, getMetricRegistry, getStageType, managedModeEnabled, preInit

Field Details

finishedRunnable

protected Runnable finishedRunnable

Constructor Details

AbstractGenerator

public AbstractGenerator()

Method Details

setStageOutput

public void setStageOutput(StageOutput<M> stageOutput)

finish

protected void finish()

onFinished

public void onFinished(Runnable finishedRunnable)

Specified by:

onFinished in interface Generator<M,C extends com.lucidworks.apollo.pipeline.StageConfig>

send

public void send(M message,
 com.lucidworks.apollo.pipeline.Context context)

Specified by:

send in interface StageOutput<M>