org.xbib.elasticsearch.plugin.jdbc.util

Class RiverServiceLoader

java.lang.Object

org.xbib.elasticsearch.plugin.jdbc.util.RiverServiceLoader

public class RiverServiceLoader
extends Object

The river service loader

Constructor Summary

Constructors

Constructor and Description
RiverServiceLoader()

Method Summary

Methods

Modifier and Type	Method and Description
static RiverFlow	newRiverFlow(String strategy) A river flow encapsulates the thread that moves the data from source to mouth
static RiverMouth	newRiverMouth(String strategy) A river mouth is the Elasticsearch side of the river, where the bulk processor lives
static RiverSource	newRiverSource(String strategy) A river source is the origin, the data producing side

Methods inherited from class java.lang.Object

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

Constructor Detail

RiverServiceLoader

public RiverServiceLoader()

Method Detail

newRiverFlow

public static RiverFlow newRiverFlow(String strategy)

A river flow encapsulates the thread that moves the data from source to mouth

Parameters:

strategy - the strategy

Returns:

a river flow, or the SimpleRiverFlow

newRiverSource

public static RiverSource newRiverSource(String strategy)

A river source is the origin, the data producing side

Parameters:

strategy - the strategy

Returns:

a river source, or the SimpleRiverSource

newRiverMouth

public static RiverMouth newRiverMouth(String strategy)

A river mouth is the Elasticsearch side of the river, where the bulk processor lives

Parameters:

strategy - the strategy

Returns:

a new instance of a river mouth, or an instance of the SimpleRiverMouth if strategy does not exist