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

Class ColumnRiverMouth

java.lang.Object

org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth

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

All Implemented Interfaces:

RiverMouth<SimpleRiverContext>

public class ColumnRiverMouth
extends SimpleRiverMouth

River mouth implementation for the 'column' strategy

Author:

Piotr Śliwa

Field Summary

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

context, id, index, indexMappings, indexSettings, ingest, ingestFactory, metric, suspended, type

Constructor Summary

Constructors

Constructor and Description
ColumnRiverMouth()

Method Summary

Methods

Modifier and Type	Method and Description
ColumnRiverMouth	newInstance() Create a new river mouth instance
String	strategy() The river strategy

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

afterFetch, beforeFetch, delete, flush, getId, getIndex, getMetric, getType, index, resume, setId, setIndex, setIndexSettings, setIngestFactory, setRiverContext, setType, setTypeMapping, shutdown, suspend

Methods inherited from class java.lang.Object

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

Constructor Detail

ColumnRiverMouth

public ColumnRiverMouth()

Method Detail

strategy

public String strategy()

Description copied from interface: RiverMouth

The river strategy

Specified by:

strategy in interface RiverMouth<SimpleRiverContext>

Overrides:

strategy in class SimpleRiverMouth

Returns:

the strategy

newInstance

public ColumnRiverMouth newInstance()

Description copied from interface: RiverMouth

Create a new river mouth instance

Specified by:

newInstance in interface RiverMouth<SimpleRiverContext>

Overrides:

newInstance in class SimpleRiverMouth

Returns:

new river mouth instance