Module org.elasticsearch.server

Package org.elasticsearch.ingest

Class SimulateIngestService

java.lang.Object

org.elasticsearch.ingest.IngestService

org.elasticsearch.ingest.SimulateIngestService

All Implemented Interfaces:

ClusterStateApplier, ReportingService<IngestInfo>

public class SimulateIngestService
extends IngestService

This is an implementation of IngestService that allows us to substitute pipeline definitions so that users can simulate ingest using pipelines that they define on the fly.

Nested Class Summary

Nested classes/interfaces inherited from class org.elasticsearch.ingest.IngestService

IngestService.DeletePipelineClusterStateUpdateTask, IngestService.PipelineClusterStateUpdateTask, IngestService.PutPipelineClusterStateUpdateTask

Nested classes/interfaces inherited from interface org.elasticsearch.node.ReportingService

ReportingService.Info

Field Summary

Fields inherited from class org.elasticsearch.ingest.IngestService

INGEST_ORIGIN, NOOP_PIPELINE_NAME

Constructor Summary

Constructors

Constructor	Description
SimulateIngestService(IngestService ingestService, BulkRequest request)

Method Summary

Modifier and Type	Method	Description
Pipeline	getPipeline(String pipelineId)	This method returns the Pipeline for the given pipelineId.

Methods inherited from class org.elasticsearch.ingest.IngestService

addIngestClusterStateListener, applyClusterState, createGrokThreadWatchdog, delete, executeBulkRequest, getClusterService, getPipelines, getPipelineWithProcessorType, getProcessorFactories, getProcessorsInPipeline, getScriptService, hasPipeline, info, isNoOpPipelineUpdate, putPipeline, reloadPipeline, resolvePipelinesAndUpdateIndexRequest, stats, validatePipelineRequest

Methods inherited from class java.lang.Object

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

Constructor Details

SimulateIngestService

public SimulateIngestService(IngestService ingestService,
 BulkRequest request)

Method Details

getPipeline

public Pipeline getPipeline(String pipelineId)

This method returns the Pipeline for the given pipelineId. If a substitute definition of the pipeline has been defined for the current simulate, then that pipeline is returned. Otherwise, the pipeline stored in the cluster state is returned.

Overrides:

getPipeline in class IngestService