org.xbib.elasticsearch.plugin.jdbc

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

java.lang.Object

org.xbib.elasticsearch.plugin.jdbc.RiverThread<T,R,P>

Type Parameters:

T - a pipeline result type

R - a pipeline request type

P - a pipeline type

All Implemented Interfaces:

Runnable

public class RiverThread<T,R extends PipelineRequest,P extends Pipeline<T,R>>
extends Object
implements Runnable

A thread that spawns a single step of river operation.

Constructor Summary

Constructors

Constructor and Description
RiverThread(RiverFlow riverFlow, List<Map<String,Object>> input)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	afterPipelineExecutions()
protected void	beforePipelineExecutions() Before the pipelines are executed, put the river defintions on the queue
void	checkForSuspension() Should be called regularly to check for a new river state, if the river is suspended.
void	run()

Methods inherited from class java.lang.Object

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

Constructor Detail

RiverThread

public RiverThread(RiverFlow riverFlow,
           List<Map<String,Object>> input)

Method Detail

beforePipelineExecutions

protected void beforePipelineExecutions()
                                 throws IOException

Before the pipelines are executed, put the river defintions on the queue

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

afterPipelineExecutions

protected void afterPipelineExecutions()
                                throws Exception

Throws:

Exception

checkForSuspension

public void checkForSuspension()

Should be called regularly to check for a new river state, if the river is suspended. If so, enter suspension mode. This is a bit tricky for a list of pipelines: first, all pipeline sources and mouths are suspended. Then, a state change is monitored for resuming. At last, all pipeline sources and mouths are resumed.