public abstract class IndexStage<C extends StageConfig> extends AbstractProcessor<PipelineDocument,C>
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
CONTEXT_TEMPLATE_KEY |
static java.lang.String |
DOC_TEMPLATE_KEY |
Modifier and Type | Method and Description |
---|---|
java.lang.Class<PipelineDocument> |
getMessageClass() |
getConfiguration, getContextFactory, getId, getMetricRegistry, handleSignal, init, process
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
handleSignal, process
getStageConfigClass
public static final java.lang.String CONTEXT_TEMPLATE_KEY
public static final java.lang.String DOC_TEMPLATE_KEY
public java.lang.Class<PipelineDocument> getMessageClass()