Modifier and Type | Class and Description |
---|---|
class |
RiverThread<T,R extends PipelineRequest,P extends Pipeline<T,R>>
A thread that spawns a single step of river operation.
|
Modifier and Type | Interface and Description |
---|---|
interface |
Pipeline<T,R extends PipelineRequest>
A pipeline.
|
interface |
PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>
The Pipeline Executor can execute provided pipelines.
|
Modifier and Type | Class and Description |
---|---|
class |
ContextPipelineElement
The context pipeline element transport a RiverContext as request to a pipeline
|
Modifier and Type | Class and Description |
---|---|
class |
MetricSimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>> |
class |
SimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>
A simple pipeline executor.
|
elasticsearch-river-jdbc