Package | Description |
---|---|
org.xbib.elasticsearch.plugin.jdbc.pipeline | |
org.xbib.elasticsearch.plugin.jdbc.pipeline.executor |
Modifier and Type | Method and Description |
---|---|
PipelineExecutor<T,R,P> |
PipelineExecutor.execute()
Execute the pipelines.
|
PipelineExecutor<T,R,P> |
PipelineExecutor.prepare()
Prepare the pipeline execution.
|
PipelineExecutor<T,R,P> |
PipelineExecutor.setConcurrency(int concurrency)
Set the concurrency of this pipeline setExecutor
|
PipelineExecutor<T,R,P> |
PipelineExecutor.setPipelineProvider(PipelineProvider<P> provider)
Set the provider of this pipeline setExecutor
|
PipelineExecutor<T,R,P> |
PipelineExecutor.waitFor()
Execute the pipelines.
|
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