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

Packages that use RiverContext

Package	Description
org.xbib.elasticsearch.plugin.jdbc
org.xbib.elasticsearch.plugin.jdbc.pipeline.element
org.xbib.elasticsearch.river.jdbc
org.xbib.elasticsearch.river.jdbc.strategy.column
org.xbib.elasticsearch.river.jdbc.strategy.simple

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

Methods in org.xbib.elasticsearch.plugin.jdbc that return RiverContext

Modifier and Type	Method and Description
RiverContext	RiverPipeline.getRiverContext()

Uses of RiverContext in org.xbib.elasticsearch.plugin.jdbc.pipeline.element

Methods in org.xbib.elasticsearch.plugin.jdbc.pipeline.element that return RiverContext

Modifier and Type	Method and Description
RiverContext	ContextPipelineElement.get()

Methods in org.xbib.elasticsearch.plugin.jdbc.pipeline.element with parameters of type RiverContext

Modifier and Type	Method and Description
ContextPipelineElement	ContextPipelineElement.set(RiverContext context)

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

Classes in org.xbib.elasticsearch.river.jdbc with type parameters of type RiverContext

Modifier and Type	Interface and Description
interface	RiverFlow<RC extends RiverContext> A RiverFlow is the controlling component for creatin RiverContexts which can be processed independently from each other.
interface	RiverMouth<RC extends RiverContext> The river mouth is the abstraction of the destination where all the data is flowing from the river source.
interface	RiverSource<RC extends RiverContext> The river source models the data producing side

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

Modifier and Type	Method and Description
RiverContext	RiverContext.release() Release all resources
RiverContext	RiverContext.setAutoCommit(boolean autocommit) Set auto commit
RiverContext	RiverContext.setColumnNameMap(Map<String,Object> columnNameMap) Set column name map.
RiverContext	RiverContext.setConnectionProperties(Map<String,Object> connectionProperties) Optional JDBC connection properties
RiverContext	RiverContext.setDefinition(Map<String,Object> definition) Set river instance definition
RiverContext	RiverContext.setFetchSize(int fetchSize) Set fetch size
RiverContext	RiverContext.setMaxRetryWait(org.elasticsearch.common.unit.TimeValue maxretrywait) Set maximum count of retries
RiverContext	RiverContext.setMaxRows(int maxRows) Set max rows
RiverContext	RiverContext.setMetric(org.elasticsearch.common.metrics.MeterMetric metric) Set metric
RiverContext	RiverContext.setQueryTimeout(int queryTimeout) Set result set query timeout
RiverContext	RiverContext.setResultSetConcurrency(String resultSetConcurrency) Set result set concurrency
RiverContext	RiverContext.setResultSetType(String resultSetType) Set result set type
RiverContext	RiverContext.setRetries(int retries) Set retries
RiverContext	RiverContext.setRiverMouth(RiverMouth riverMouth) Set river mouth
RiverContext	RiverContext.setRiverSource(RiverSource riverSource) Set river source
RiverContext	RiverContext.setRiverState(RiverState riverState) Set river state
RiverContext	RiverContext.setRounding(String rounding) Set rounding of big decimal values.
RiverContext	RiverContext.setScale(int scale) Set scale of big decimal values.
RiverContext	RiverContext.setStatements(List<SQLCommand> sql) Set the list of SQL statements
RiverContext	RiverContext.shouldIgnoreNull(boolean shouldIgnoreNull) Should null values in columns be ignored for indexing
RiverContext	RiverContext.shouldPrepareDatabaseMetadata(boolean shouldPrepareDatabaseMetadata) Should database metadata be used in parameter variables
RiverContext	RiverContext.shouldPrepareResultSetMetadata(boolean shouldPrepareResultSetMetadata) Should result set metadata be used in parameter variables
RiverContext	RiverContext.shouldTreatBinaryAsString(boolean shouldTreatBinaryAsString) Should binary types (byte arrays) be treated as JSON strings

Methods in org.xbib.elasticsearch.river.jdbc that return types with arguments of type RiverContext

Modifier and Type	Method and Description
Queue<RiverContext>	RiverFlow.getQueue() Get queue for RiverContext processing

Methods in org.xbib.elasticsearch.river.jdbc with parameters of type RiverContext

Modifier and Type	Method and Description
void	RiverFlow.logMetrics(RiverContext riverContext, String cause) Log metrics

Method parameters in org.xbib.elasticsearch.river.jdbc with type arguments of type RiverContext

Modifier and Type	Method and Description
RiverFlow	RiverFlow.setQueue(Queue<RiverContext> queue) Set queue for processing RiverContext requests

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

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

Modifier and Type	Class and Description
class	ColumnRiverContext

Methods in org.xbib.elasticsearch.river.jdbc.strategy.column with parameters of type RiverContext

Modifier and Type	Method and Description
protected void	ColumnRiverFlow.fetch(RiverContext riverContext)

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

Classes in org.xbib.elasticsearch.river.jdbc.strategy.simple with type parameters of type RiverContext

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

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

Modifier and Type	Class and Description
class	SimpleRiverContext The river context consists of the parameters that span source and mouth settings.

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

Modifier and Type	Method and Description
RiverContext	SimpleRiverContext.setMetric(org.elasticsearch.common.metrics.MeterMetric metric)

Methods in org.xbib.elasticsearch.river.jdbc.strategy.simple that return types with arguments of type RiverContext

Modifier and Type	Method and Description
Queue<RiverContext>	SimpleRiverFlow.getQueue()

Methods in org.xbib.elasticsearch.river.jdbc.strategy.simple with parameters of type RiverContext

Modifier and Type	Method and Description
protected void	SimpleRiverFlow.afterFetch(RiverContext riverContext) After the river task has completed a single run, this method is called.
protected void	SimpleRiverFlow.fetch(RiverContext riverContext) After river context and state setup, when data should be fetched from river source, this method is called.
void	SimpleRiverFlow.logMetrics(RiverContext riverContext, String cause)

Method parameters in org.xbib.elasticsearch.river.jdbc.strategy.simple with type arguments of type RiverContext

Modifier and Type	Method and Description
RiverFlow	SimpleRiverFlow.setQueue(Queue<RiverContext> queue)