Package com.lucidworks.apollo.pipeline

Interface Stage<M,C extends com.lucidworks.apollo.pipeline.StageConfig>

All Superinterfaces:

Configurable<C>, Processor<M>

All Known Subinterfaces:

Generator<M,C>

All Known Implementing Classes:

AbstractGenerator, AbstractProcessor, AbstractStage, RuntimeStage

public interface Stage<M,C extends com.lucidworks.apollo.pipeline.StageConfig>
extends Processor<M>, Configurable<C>

The basic unit of a pipeline, a stage

Method Summary

Modifier and Type	Method	Description
com.lucidworks.apollo.pipeline.ContextFactory	getContextFactory()
String	getId()
Class<M>	getMessageClass()
com.codahale.metrics.MetricRegistry	getMetricRegistry()
default String	getStageType()
boolean	managedModeEnabled()
default void	preInit(StageAssistFactoryParams params)

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

getConfiguration, getProperty, init

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

handleSignal, process

Method Details

getId

String getId()

getMessageClass

Class<M> getMessageClass()

getContextFactory

com.lucidworks.apollo.pipeline.ContextFactory getContextFactory()

getMetricRegistry

com.codahale.metrics.MetricRegistry getMetricRegistry()

managedModeEnabled

boolean managedModeEnabled()

getStageType

default String getStageType()

preInit

default void preInit(StageAssistFactoryParams params)