Uses of Interface
org.xbib.elasticsearch.river.jdbc.RiverFlow

Packages that use RiverFlow

Package	Description
org.xbib.elasticsearch.plugin.jdbc
org.xbib.elasticsearch.plugin.jdbc.feeder
org.xbib.elasticsearch.plugin.jdbc.util
org.xbib.elasticsearch.river.jdbc
org.xbib.elasticsearch.river.jdbc.strategy.column
org.xbib.elasticsearch.river.jdbc.strategy.simple

Uses of RiverFlow in org.xbib.elasticsearch.plugin.jdbc

Constructors in org.xbib.elasticsearch.plugin.jdbc with parameters of type RiverFlow

Constructor and Description
RiverPipeline(RiverFlow riverFlow)
RiverThread(RiverFlow riverFlow, List<Map<String,Object>> input)

Uses of RiverFlow in org.xbib.elasticsearch.plugin.jdbc.feeder

Methods in org.xbib.elasticsearch.plugin.jdbc.feeder that return RiverFlow

Modifier and Type	Method and Description
protected RiverFlow	JDBCFeeder.createRiverFlow(Map<String,Object> spec, org.elasticsearch.common.settings.Settings settings)

Uses of RiverFlow in org.xbib.elasticsearch.plugin.jdbc.util

Methods in org.xbib.elasticsearch.plugin.jdbc.util that return RiverFlow

Modifier and Type	Method and Description
static RiverFlow	RiverServiceLoader.newRiverFlow(String strategy) A river flow encapsulates the thread that moves the data from source to mouth

Uses of RiverFlow in org.xbib.elasticsearch.river.jdbc

Methods in org.xbib.elasticsearch.river.jdbc that return RiverFlow

Modifier and Type	Method and Description
RiverFlow<RC>	RiverFlow.newInstance()
RiverFlow	RiverFlow.setClient(org.elasticsearch.client.Client client)
RiverFlow	RiverFlow.setIngestFactory(IngestFactory ingestFactory) Set ingest factory
RiverFlow	RiverFlow.setMetric(org.elasticsearch.common.metrics.MeterMetric meterMetric) Set metric
RiverFlow	RiverFlow.setQueue(Queue<RiverContext> queue) Set queue for processing RiverContext requests
RiverFlow	RiverFlow.setRiverName(org.elasticsearch.river.RiverName riverName) Sets the river name
RiverFlow	RiverFlow.setSettings(org.elasticsearch.common.settings.Settings settings) Set the settings

Uses of RiverFlow in org.xbib.elasticsearch.river.jdbc.strategy.column

Classes in org.xbib.elasticsearch.river.jdbc.strategy.column that implement RiverFlow

Modifier and Type	Class and Description
class	ColumnRiverFlow River flow implementation for the 'column' strategy

Uses of RiverFlow in org.xbib.elasticsearch.river.jdbc.strategy.simple

Classes in org.xbib.elasticsearch.river.jdbc.strategy.simple that implement RiverFlow

Modifier and Type	Class and Description
class	SimpleRiverFlow<RC extends RiverContext> Simple river flow implementation

Methods in org.xbib.elasticsearch.river.jdbc.strategy.simple that return RiverFlow

Modifier and Type	Method and Description
RiverFlow	SimpleRiverFlow.setClient(org.elasticsearch.client.Client client)
RiverFlow	SimpleRiverFlow.setIngestFactory(IngestFactory ingestFactory)
RiverFlow	SimpleRiverFlow.setMetric(org.elasticsearch.common.metrics.MeterMetric meterMetric)
RiverFlow	SimpleRiverFlow.setQueue(Queue<RiverContext> queue)
RiverFlow	SimpleRiverFlow.setRiverName(org.elasticsearch.river.RiverName riverName)
RiverFlow	SimpleRiverFlow.setSettings(org.elasticsearch.common.settings.Settings settings)