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

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

java.lang.Object

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

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

All Implemented Interfaces:

PipelineExecutor<T,R,P>

public class MetricSimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>
extends SimplePipelineExecutor<T,R,P>

Constructor Summary

Constructors

Constructor and Description
MetricSimplePipelineExecutor(org.elasticsearch.common.metrics.MeterMetric meterMetric)

Method Summary

Methods

Modifier and Type	Method and Description
MetricSimplePipelineExecutor<T,R,P>	execute() Execute pipelines
org.elasticsearch.common.metrics.MeterMetric	metric()
MetricSimplePipelineExecutor<T,R,P>	prepare() Prepare the pipeline execution.
MetricSimplePipelineExecutor<T,R,P>	setConcurrency(int concurrency) Set the concurrency of this pipeline setExecutor
MetricSimplePipelineExecutor<T,R,P>	setPipelineProvider(PipelineProvider<P> provider) Set the provider of this pipeline setExecutor
MetricSimplePipelineExecutor<T,R,P>	waitFor() Wait for all results of the executions.

Methods inherited from class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor

getExceptions, getPipelines, shutdown

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricSimplePipelineExecutor

public MetricSimplePipelineExecutor(org.elasticsearch.common.metrics.MeterMetric meterMetric)

Method Detail

setConcurrency

public MetricSimplePipelineExecutor<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>>

Overrides:

setConcurrency in class SimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Parameters:

concurrency - the concurrency, must be a positive integer

Returns:

this setExecutor

setPipelineProvider

public MetricSimplePipelineExecutor<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>>

Overrides:

setPipelineProvider in class SimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Parameters:

provider - the pipeline provider

Returns:

this setExecutor

prepare

public MetricSimplePipelineExecutor<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>>

Overrides:

prepare in class SimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Returns:

this setExecutor

execute

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

Description copied from class: SimplePipelineExecutor

Execute pipelines

Specified by:

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

Overrides:

execute in class SimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Returns:

this executor

waitFor

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

Description copied from class: SimplePipelineExecutor

Wait for all results of the executions.

Specified by:

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

Overrides:

waitFor in class SimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>>

Returns:

this pipeline executor

Throws:

InterruptedException

ExecutionException

metric

public org.elasticsearch.common.metrics.MeterMetric metric()