| Package | Description |
|---|---|
| org.xbib.elasticsearch.plugin.jdbc.pipeline.executor |
| Modifier and Type | Class and Description |
|---|---|
class |
MetricSimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>> |
| Modifier and Type | Method and Description |
|---|---|
SimplePipelineExecutor<T,R,P> |
SimplePipelineExecutor.execute()
Execute pipelines
|
SimplePipelineExecutor<T,R,P> |
SimplePipelineExecutor.prepare() |
SimplePipelineExecutor<T,R,P> |
SimplePipelineExecutor.setConcurrency(int concurrency) |
SimplePipelineExecutor<T,R,P> |
SimplePipelineExecutor.setPipelineProvider(PipelineProvider<P> provider) |
SimplePipelineExecutor<T,R,P> |
SimplePipelineExecutor.waitFor()
Wait for all results of the executions.
|
elasticsearch-river-jdbc