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