com.lucidworks.apollo.pipeline.index

Class IndexPipeline

java.lang.Object

com.lucidworks.apollo.pipeline.Pipeline<PipelineDocument>

com.lucidworks.apollo.pipeline.index.IndexPipeline

All Implemented Interfaces:

Lifecycle

public class IndexPipeline
extends Pipeline<PipelineDocument>

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	IndexPipeline.PipelineDocumentIterator Iterator that will read from a queue until it reaches a poison pill object, or a given Future has an error, or reading from the queue times out

Nested classes/interfaces inherited from class com.lucidworks.apollo.pipeline.Pipeline

Pipeline.State

Constructor Summary

Constructors

Constructor and Description
IndexPipeline(java.lang.String instanceId, java.lang.String pipelineId, java.util.List<StageConfig> stageConfigs, StageFactory<PipelineDocument> stageFactory, MetricRegistry globalMetricRegistry, MetricRegistry metricRegistry, ConfigurationComponent configurationComponent, java.util.Map<java.lang.String,java.lang.String> initialProperties)

Method Summary

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

addStateListener, getErrors, getInstanceId, getMetrics, getPipelineId, getProperties, getRunningTimeMs, getStages, getStartTime, getState, isInState, isTerminalState, maybeStop, send, send, send, send, sendEndOfBatch, start, stop

Methods inherited from class java.lang.Object

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

Constructor Detail

IndexPipeline

public IndexPipeline(java.lang.String instanceId,
                     java.lang.String pipelineId,
                     java.util.List<StageConfig> stageConfigs,
                     StageFactory<PipelineDocument> stageFactory,
                     MetricRegistry globalMetricRegistry,
                     MetricRegistry metricRegistry,
                     ConfigurationComponent configurationComponent,
                     java.util.Map<java.lang.String,java.lang.String> initialProperties)