org.xbib.elasticsearch.plugin.jdbc.pipeline.executor

Class SimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

java.lang.Object

org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor<T,R,P>

Type Parameters:

T - the pipeline result type

R - the pipeline request type

P - the pipeline type

All Implemented Interfaces:

PipelineExecutor<T,R,P>

Direct Known Subclasses:

MetricSimplePipelineExecutor

public class SimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>
extends Object
implements PipelineExecutor<T,R,P>

A simple pipeline executor.

Constructor Summary

Constructors

Constructor and Description
SimplePipelineExecutor()

Method Summary

Methods

Modifier and Type	Method and Description
SimplePipelineExecutor<T,R,P>	execute() Execute pipelines
List<Throwable>	getExceptions() Get the collected I/O exceptions that were thrown by the pipelines.
Collection<P>	getPipelines() Get the pipelines of this executor.
SimplePipelineExecutor<T,R,P>	prepare() Prepare the pipeline execution.
SimplePipelineExecutor<T,R,P>	setConcurrency(int concurrency) Set the concurrency of this pipeline setExecutor
SimplePipelineExecutor<T,R,P>	setPipelineProvider(PipelineProvider<P> provider) Set the provider of this pipeline setExecutor
void	shutdown() Shut down this pipeline executor.
SimplePipelineExecutor<T,R,P>	waitFor() Wait for all results of the executions.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SimplePipelineExecutor

public SimplePipelineExecutor()

Method Detail

setConcurrency

public SimplePipelineExecutor<T,R,P> setConcurrency(int concurrency)

Description copied from interface: PipelineExecutor

Set the concurrency of this pipeline setExecutor

Specified by:

setConcurrency in interface PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Parameters:

concurrency - the concurrency, must be a positive integer

Returns:

this setExecutor

setPipelineProvider

public SimplePipelineExecutor<T,R,P> setPipelineProvider(PipelineProvider<P> provider)

Description copied from interface: PipelineExecutor

Set the provider of this pipeline setExecutor

Specified by:

setPipelineProvider in interface PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Parameters:

provider - the pipeline provider

Returns:

this setExecutor

prepare

public SimplePipelineExecutor<T,R,P> prepare()

Description copied from interface: PipelineExecutor

Prepare the pipeline execution.

Specified by:

prepare in interface PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Returns:

this setExecutor

execute

public SimplePipelineExecutor<T,R,P> execute()

Execute pipelines

Specified by:

execute in interface PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Returns:

this executor

waitFor

public SimplePipelineExecutor<T,R,P> waitFor()
                                                                                    throws InterruptedException,
                                                                                           ExecutionException

Wait for all results of the executions.

Specified by:

waitFor in interface PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Returns:

this pipeline executor

Throws:

InterruptedException

ExecutionException

shutdown

public void shutdown()
              throws IOException

Description copied from interface: PipelineExecutor

Shut down this pipeline executor.

Specified by:

shutdown in interface PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Throws:

IOException

getPipelines

public Collection<P> getPipelines()

Get the pipelines of this executor.

Specified by:

getPipelines in interface PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Returns:

the pipelines

getExceptions

public List<Throwable> getExceptions()

Get the collected I/O exceptions that were thrown by the pipelines.

Returns:

list of exceptions