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

Class ColumnRiverSource<RC extends ColumnRiverContext>

java.lang.Object

org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource<RC>

org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSource<RC>

All Implemented Interfaces:

RiverSource<RC>

public class ColumnRiverSource<RC extends ColumnRiverContext>
extends SimpleRiverSource<RC>

River source implementation for the 'column' strategy

Author:

Piotr Śliwa

Field Summary

Fields inherited from class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource

calendar, context, dateTimeZone, locale, password, readConnection, suspended, timezone, url, user, writeConnection

Constructor Summary

Constructors

Constructor and Description
ColumnRiverSource()

Method Summary

Methods

Modifier and Type	Method and Description
void	fetch() River fetch.
ColumnRiverSource<RC>	newInstance() Create new river source instance
String	strategy() The strategy this river source supports.

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

afterFetch, afterRows, afterRows, beforeFetch, beforeRows, beforeRows, bind, close, close, closeReading, closeWriting, executeQuery, executeQuery, executeUpdate, executeUpdate, getConnectionForReading, getConnectionForWriting, getLocale, getTimeZone, getUrl, merge, nextRow, nextRow, parseType, prepareQuery, prepareUpdate, register, resume, setLocale, setPassword, setRiverContext, setTimeZone, setUrl, setUser, shutdown, suspend

Methods inherited from class java.lang.Object

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

Constructor Detail

ColumnRiverSource

public ColumnRiverSource()

Method Detail

strategy

public String strategy()

Description copied from interface: RiverSource

The strategy this river source supports.

Specified by:

strategy in interface RiverSource<RC extends ColumnRiverContext>

Overrides:

strategy in class SimpleRiverSource<RC extends ColumnRiverContext>

Returns:

the strategy as a string

newInstance

public ColumnRiverSource<RC> newInstance()

Description copied from interface: RiverSource

Create new river source instance

Specified by:

newInstance in interface RiverSource<RC extends ColumnRiverContext>

Overrides:

newInstance in class SimpleRiverSource<RC extends ColumnRiverContext>

Returns:

a new river source instance

fetch

public void fetch()
           throws SQLException,
                  IOException

Description copied from class: SimpleRiverSource

River fetch. Issue a series of SQL statements.

Specified by:

fetch in interface RiverSource<RC extends ColumnRiverContext>

Overrides:

fetch in class SimpleRiverSource<RC extends ColumnRiverContext>

Throws:

SQLException - when SQL execution gives an error

IOException - when input/output error occurs