Package org.elasticsearch.ingest
Class Processor.Parameters
- java.lang.Object
-
- org.elasticsearch.ingest.Processor.Parameters
-
- Enclosing interface:
- Processor
public static class Processor.Parameters extends java.lang.Object
Infrastructure class that holds services that can be used by processor factories to create processor instances and that gets passed around to allIngestPlugin
s.
-
-
Field Summary
Fields Modifier and Type Field Description AnalysisRegistry
analysisRegistry
Provide analyzer supportClient
client
Provides access to the node clientEnvironment
env
Useful to provide access to the node's environment like config directory to processor factories.java.util.function.Consumer<java.lang.Runnable>
genericExecutor
IngestService
ingestService
java.util.function.LongSupplier
relativeTimeSupplier
java.util.function.BiFunction<java.lang.Long,java.lang.Runnable,Scheduler.ScheduledCancellable>
scheduler
Provides scheduler supportScriptService
scriptService
Provides processors script support.ThreadContext
threadContext
Allows processors to read headers set byActionFilter
instances that have run prior to in ingest.
-
Constructor Summary
Constructors Constructor Description Parameters(Environment env, ScriptService scriptService, AnalysisRegistry analysisRegistry, ThreadContext threadContext, java.util.function.LongSupplier relativeTimeSupplier, java.util.function.BiFunction<java.lang.Long,java.lang.Runnable,Scheduler.ScheduledCancellable> scheduler, IngestService ingestService, Client client, java.util.function.Consumer<java.lang.Runnable> genericExecutor)
-
-
-
Field Detail
-
env
public final Environment env
Useful to provide access to the node's environment like config directory to processor factories.
-
scriptService
public final ScriptService scriptService
Provides processors script support.
-
analysisRegistry
public final AnalysisRegistry analysisRegistry
Provide analyzer support
-
threadContext
public final ThreadContext threadContext
Allows processors to read headers set byActionFilter
instances that have run prior to in ingest.
-
relativeTimeSupplier
public final java.util.function.LongSupplier relativeTimeSupplier
-
ingestService
public final IngestService ingestService
-
genericExecutor
public final java.util.function.Consumer<java.lang.Runnable> genericExecutor
-
scheduler
public final java.util.function.BiFunction<java.lang.Long,java.lang.Runnable,Scheduler.ScheduledCancellable> scheduler
Provides scheduler support
-
client
public final Client client
Provides access to the node client
-
-
Constructor Detail
-
Parameters
public Parameters(Environment env, ScriptService scriptService, AnalysisRegistry analysisRegistry, ThreadContext threadContext, java.util.function.LongSupplier relativeTimeSupplier, java.util.function.BiFunction<java.lang.Long,java.lang.Runnable,Scheduler.ScheduledCancellable> scheduler, IngestService ingestService, Client client, java.util.function.Consumer<java.lang.Runnable> genericExecutor)
-
-