org.xbib.elasticsearch.plugin.jdbc.river

Class JDBCRiver

java.lang.Object

org.elasticsearch.river.AbstractRiverComponent

org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiver

All Implemented Interfaces:

Runnable, org.elasticsearch.river.River, org.elasticsearch.river.RiverComponent, RunnableRiver, StatefulRiver

public class JDBCRiver
extends org.elasticsearch.river.AbstractRiverComponent
implements StatefulRiver, RunnableRiver

JDBC river

Field Summary

Fields inherited from class org.elasticsearch.river.AbstractRiverComponent

riverName, settings

Constructor Summary

Constructors

Constructor and Description
JDBCRiver(org.elasticsearch.river.RiverName riverName, org.elasticsearch.river.RiverSettings riverSettings, org.elasticsearch.client.Client client)

Method Summary

Methods

Modifier and Type	Method and Description
void	close() Called form Elasticsearch when river is deleted.
RiverState	getRiverState()
void	run() Execute river once from execute API, no matter if schedule/interval is defined.
void	start() Called from Elasticsearch after recovery of indices when a node has initialized.

Methods inherited from class org.elasticsearch.river.AbstractRiverComponent

nodeName, riverName

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.elasticsearch.river.RiverComponent

riverName

Constructor Detail

JDBCRiver

@Inject
public JDBCRiver(org.elasticsearch.river.RiverName riverName,
                org.elasticsearch.river.RiverSettings riverSettings,
                org.elasticsearch.client.Client client)

Method Detail

start

public void start()

Called from Elasticsearch after recovery of indices when a node has initialized.

Specified by:

start in interface org.elasticsearch.river.River

close

public void close()

Called form Elasticsearch when river is deleted.

Specified by:

close in interface org.elasticsearch.river.River

run

public void run()

Execute river once from execute API, no matter if schedule/interval is defined. If river is running, prevoius instance are interrupted and closed.

Specified by:

run in interface Runnable

getRiverState

public RiverState getRiverState()

Specified by:

getRiverState in interface StatefulRiver