public abstract class DocumentGenerator<C extends StageConfig> extends AbstractGenerator<PipelineDocument,C>
Modifier and Type | Method and Description |
---|---|
java.lang.Class<PipelineDocument> |
getMessageClass() |
onFinished, send, setStageOutput
getConfiguration, getContextFactory, getId, getMetricRegistry, handleSignal, init, process
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
getContextFactory, getId, getMetricRegistry
handleSignal, process
getConfiguration, getStageConfigClass, init
public java.lang.Class<PipelineDocument> getMessageClass()