Package org.elasticsearch.ingest
Class IngestService
java.lang.Object
org.elasticsearch.ingest.IngestService
- All Implemented Interfaces:
ClusterStateApplier
,ReportingService<IngestInfo>
public class IngestService extends java.lang.Object implements ClusterStateApplier, ReportingService<IngestInfo>
Holder class for several ingest related services.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.node.ReportingService
ReportingService.Info
-
Field Summary
Fields Modifier and Type Field Description static java.lang.String
INGEST_ORIGIN
static java.lang.String
NOOP_PIPELINE_NAME
-
Constructor Summary
Constructors Constructor Description IngestService(ClusterService clusterService, ThreadPool threadPool, Environment env, ScriptService scriptService, AnalysisRegistry analysisRegistry, java.util.List<IngestPlugin> ingestPlugins, Client client)
-
Method Summary
Modifier and Type Method Description void
addIngestClusterStateListener(java.util.function.Consumer<ClusterState> listener)
Adds a listener that gets invoked with the current cluster state before processor factories get invoked.void
applyClusterState(ClusterChangedEvent event)
Called when a new cluster state (ClusterChangedEvent.state()
needs to be applied.void
delete(DeletePipelineRequest request, ActionListener<AcknowledgedResponse> listener)
Deletes the pipeline specified by id in the request.void
executeBulkRequest(int numberOfActionRequests, java.lang.Iterable<DocWriteRequest<?>> actionRequests, java.util.function.BiConsumer<java.lang.Integer,java.lang.Exception> onFailure, java.util.function.BiConsumer<java.lang.Thread,java.lang.Exception> onCompletion, java.util.function.IntConsumer onDropped)
ClusterService
getClusterService()
Pipeline
getPipeline(java.lang.String id)
Returns the pipeline by the specified idstatic java.util.List<PipelineConfiguration>
getPipelines(ClusterState clusterState, java.lang.String... ids)
java.util.Map<java.lang.String,Processor.Factory>
getProcessorFactories()
<P extends Processor>
java.util.List<P>getProcessorsInPipeline(java.lang.String pipelineId, java.lang.Class<P> clazz)
Gets all the Processors of the given type from within a Pipeline.ScriptService
getScriptService()
IngestInfo
info()
static ClusterState
innerPut(PutPipelineRequest request, ClusterState currentState)
void
putPipeline(java.util.Map<DiscoveryNode,IngestInfo> ingestInfos, PutPipelineRequest request, ActionListener<AcknowledgedResponse> listener)
Stores the specified pipeline definition in the request.static boolean
resolvePipelines(DocWriteRequest<?> originalRequest, IndexRequest indexRequest, Metadata metadata)
IngestStats
stats()
-
Field Details
-
NOOP_PIPELINE_NAME
public static final java.lang.String NOOP_PIPELINE_NAME- See Also:
- Constant Field Values
-
INGEST_ORIGIN
public static final java.lang.String INGEST_ORIGIN- See Also:
- Constant Field Values
-
-
Constructor Details
-
IngestService
public IngestService(ClusterService clusterService, ThreadPool threadPool, Environment env, ScriptService scriptService, AnalysisRegistry analysisRegistry, java.util.List<IngestPlugin> ingestPlugins, Client client)
-
-
Method Details
-
resolvePipelines
public static boolean resolvePipelines(DocWriteRequest<?> originalRequest, IndexRequest indexRequest, Metadata metadata) -
getClusterService
-
getScriptService
-
delete
Deletes the pipeline specified by id in the request. -
getPipelines
public static java.util.List<PipelineConfiguration> getPipelines(ClusterState clusterState, java.lang.String... ids)- Returns:
- pipeline configuration specified by id. If multiple ids or wildcards are specified multiple pipelines may be returned
-
putPipeline
public void putPipeline(java.util.Map<DiscoveryNode,IngestInfo> ingestInfos, PutPipelineRequest request, ActionListener<AcknowledgedResponse> listener) throws java.lang.ExceptionStores the specified pipeline definition in the request.- Throws:
java.lang.Exception
-
getPipeline
Returns the pipeline by the specified id -
getProcessorFactories
-
info
- Specified by:
info
in interfaceReportingService<IngestInfo>
-
innerPut
-
executeBulkRequest
public void executeBulkRequest(int numberOfActionRequests, java.lang.Iterable<DocWriteRequest<?>> actionRequests, java.util.function.BiConsumer<java.lang.Integer,java.lang.Exception> onFailure, java.util.function.BiConsumer<java.lang.Thread,java.lang.Exception> onCompletion, java.util.function.IntConsumer onDropped) -
stats
-
addIngestClusterStateListener
Adds a listener that gets invoked with the current cluster state before processor factories get invoked. This is useful for components that are used by ingest processors, so that they have the opportunity to update before these components get used by the ingest processor factory. -
applyClusterState
Description copied from interface:ClusterStateApplier
Called when a new cluster state (ClusterChangedEvent.state()
needs to be applied. The cluster state to be applied is already committed when this method is called, so an applier must therefore be prepared to deal with any state it receives without throwing an exception. Throwing an exception from an applier is very bad because it will stop the application of this state before it has reached all the other appliers, and will likely result in another attempt to apply the same (or very similar) cluster state which might continue until this node is removed from the cluster.- Specified by:
applyClusterState
in interfaceClusterStateApplier
-
getProcessorsInPipeline
public <P extends Processor> java.util.List<P> getProcessorsInPipeline(java.lang.String pipelineId, java.lang.Class<P> clazz)Gets all the Processors of the given type from within a Pipeline.- Parameters:
pipelineId
- the pipeline to inspectclazz
- the Processor class to look for- Returns:
- True if the pipeline contains an instance of the Processor class passed in
-