org.xbib.elasticsearch.plugin.jdbc.pipeline

Interface PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Type Parameters:

T - the result type

R - the request type

P - the pipeline type

All Known Implementing Classes:

MetricSimplePipelineExecutor, SimplePipelineExecutor

public interface PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

The Pipeline Executor can execute provided pipelines. If the concurrency level is set to higher than one, more than one pipeline is executed in parallel.

Method Summary

Methods

Modifier and Type	Method and Description
PipelineExecutor<T,R,P>	execute() Execute the pipelines.
Collection<P>	getPipelines() Return pipelines
PipelineExecutor<T,R,P>	prepare() Prepare the pipeline execution.
PipelineExecutor<T,R,P>	setConcurrency(int concurrency) Set the concurrency of this pipeline setExecutor
PipelineExecutor<T,R,P>	setPipelineProvider(PipelineProvider<P> provider) Set the provider of this pipeline setExecutor
void	shutdown() Shut down this pipeline executor.
PipelineExecutor<T,R,P>	waitFor() Execute the pipelines.

Method Detail

setConcurrency

PipelineExecutor<T,R,P> setConcurrency(int concurrency)

Set the concurrency of this pipeline setExecutor

Parameters:

concurrency - the concurrency, must be a positive integer

Returns:

this setExecutor

setPipelineProvider

PipelineExecutor<T,R,P> setPipelineProvider(PipelineProvider<P> provider)

Set the provider of this pipeline setExecutor

Parameters:

provider - the pipeline provider

Returns:

this setExecutor

prepare

PipelineExecutor<T,R,P> prepare()

Prepare the pipeline execution.

Returns:

this setExecutor

execute

PipelineExecutor<T,R,P> execute()

Execute the pipelines.

Returns:

this setExecutor

waitFor

PipelineExecutor<T,R,P> waitFor()
                                                                              throws InterruptedException,
                                                                                     ExecutionException,
                                                                                     IOException

Execute the pipelines.

Returns:

this setExecutor

Throws:

InterruptedException

ExecutionException

IOException

shutdown

void shutdown()
              throws InterruptedException,
                     ExecutionException,
                     IOException

Shut down this pipeline executor.

Throws:

InterruptedException

ExecutionException

IOException

getPipelines

Collection<P> getPipelines()

Return pipelines

Returns:

the pipelines