org.xbib.elasticsearch.river.jdbc.strategy.column

Class ColumnRiverFlow

java.lang.Object

org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow<ColumnRiverContext>

org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlow

All Implemented Interfaces:

RiverFlow<ColumnRiverContext>

public class ColumnRiverFlow
extends SimpleRiverFlow<ColumnRiverContext>

River flow implementation for the 'column' strategy

Author:

Piotr Śliwa

Field Summary

Fields

Modifier and Type	Field and Description
static String	CURRENT_RUN_STARTED_TIME
static String	LAST_RUN_TIME

Constructor Summary

Constructors

Constructor and Description
ColumnRiverFlow()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	fetch(RiverContext riverContext) After river context and state setup, when data should be fetched from river source, this method is called.
protected ColumnRiverContext	fillRiverContext(ColumnRiverContext riverContext, RiverState state, RiverSource riverSource, RiverMouth riverMouth)
ColumnRiverFlow	newInstance()
ColumnRiverContext	newRiverContext() Create a new river context for a river run
String	strategy() The name of the strategy the river flow belongs to

Methods inherited from class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow

afterFetch, beforeFetch, createRiverMouth, createRiverSource, execute, getClient, getMetric, getQueue, getRiverName, getSettings, logMetrics, setClient, setIngestFactory, setMetric, setQueue, setRiverName, setSettings

Methods inherited from class java.lang.Object

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

Field Detail

LAST_RUN_TIME

public static final String LAST_RUN_TIME

See Also:

Constant Field Values

CURRENT_RUN_STARTED_TIME

public static final String CURRENT_RUN_STARTED_TIME

See Also:

Constant Field Values

Constructor Detail

ColumnRiverFlow

public ColumnRiverFlow()

Method Detail

strategy

public String strategy()

Description copied from interface: RiverFlow

The name of the strategy the river flow belongs to

Specified by:

strategy in interface RiverFlow<ColumnRiverContext>

Overrides:

strategy in class SimpleRiverFlow<ColumnRiverContext>

Returns:

the strategy name

newInstance

public ColumnRiverFlow newInstance()

Specified by:

newInstance in interface RiverFlow<ColumnRiverContext>

Overrides:

newInstance in class SimpleRiverFlow<ColumnRiverContext>

newRiverContext

public ColumnRiverContext newRiverContext()

Description copied from interface: RiverFlow

Create a new river context for a river run

Specified by:

newRiverContext in interface RiverFlow<ColumnRiverContext>

Overrides:

newRiverContext in class SimpleRiverFlow<ColumnRiverContext>

Returns:

a new river context

fillRiverContext

protected ColumnRiverContext fillRiverContext(ColumnRiverContext riverContext,
                                  RiverState state,
                                  RiverSource riverSource,
                                  RiverMouth riverMouth)
                                       throws IOException

Overrides:

fillRiverContext in class SimpleRiverFlow<ColumnRiverContext>

Throws:

IOException

fetch

protected void fetch(RiverContext riverContext)
              throws Exception

Description copied from class: SimpleRiverFlow

After river context and state setup, when data should be fetched from river source, this method is called. The default is to invoke the fetch() method of the river source.

Overrides:

fetch in class SimpleRiverFlow<ColumnRiverContext>

Throws:

Exception