org.xbib.elasticsearch.plugin.jdbc

Class RiverPipeline

java.lang.Object

org.xbib.elasticsearch.plugin.jdbc.RiverPipeline

All Implemented Interfaces:

Callable<Boolean>, Iterator<ContextPipelineElement>, Pipeline<Boolean,ContextPipelineElement>

public class RiverPipeline
extends Object
implements Pipeline<Boolean,ContextPipelineElement>

A river pipeline is a collection of threads that can be executed in parallel during a river run

Constructor Summary

Constructors

Constructor and Description
RiverPipeline(RiverFlow riverFlow)

Method Summary

Methods

Modifier and Type	Method and Description
Boolean	call() Call this thread.
RiverContext	getRiverContext()
boolean	hasNext()
boolean	isInterrupted()
ContextPipelineElement	next()
void	remove() Removing pipeline requests is not supported.
void	setInterrupted(boolean interrupted)

Methods inherited from class java.lang.Object

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

Constructor Detail

RiverPipeline

public RiverPipeline(RiverFlow riverFlow)

Method Detail

setInterrupted

public void setInterrupted(boolean interrupted)

isInterrupted

public boolean isInterrupted()

call

public Boolean call()
             throws Exception

Call this thread. Iterate over all request and pass them to request listeners. At least, this pipeline itself can listen to requests and handle errors. Only PipelineExceptions are handled for each listener. Other execptions will quit the pipeline request executions.

Specified by:

call in interface Callable<Boolean>

Returns:

a metric about the pipeline request executions.

Throws:

Exception - if pipeline execution was sborted by a non-PipelineException

remove

public void remove()

Removing pipeline requests is not supported.

Specified by:

remove in interface Iterator<ContextPipelineElement>

hasNext

public boolean hasNext()

Specified by:

hasNext in interface Iterator<ContextPipelineElement>

next

public ContextPipelineElement next()

Specified by:

next in interface Iterator<ContextPipelineElement>

getRiverContext

public RiverContext getRiverContext()