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

Packages that use RiverSource

Package	Description
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 RiverSource in org.xbib.elasticsearch.plugin.jdbc.util

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

Modifier and Type	Method and Description
static RiverSource	RiverServiceLoader.newRiverSource(String strategy) A river source is the origin, the data producing side

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

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

Modifier and Type	Method and Description
RiverSource	RiverSource.bind(PreparedStatement statement, List<Object> values) Bind query variables
RiverSource	RiverSource.close(ResultSet result) Close result set
RiverSource	RiverSource.close(Statement statement) Close statement
RiverSource	RiverSource.closeReading() Close reading from this river source
RiverSource	RiverSource.closeWriting() Close writing to this river source
RiverSource	RiverSource.executeUpdate(PreparedStatement statement) Execute insert/update
RiverSource	RiverSource.executeUpdate(Statement statement, String sql) Execute insert update
RiverSource	RiverContext.getRiverSource() Get river source
RiverSource<RC>	RiverSource.newInstance() Create new river source instance
RiverSource	RiverSource.register(CallableStatement statement, Map<String,Object> values) Register output variables for callable statement
RiverSource	RiverSource.setLocale(Locale locale) Set the locale for JDBC
RiverSource	RiverSource.setPassword(String password) Set the password authentication
RiverSource	RiverSource.setRiverContext(RC context) Set the river context
RiverSource	RiverSource.setTimeZone(TimeZone timeZone) Set the timezone for JDBC setTimestamp() calls with calendar object.
RiverSource	RiverSource.setUrl(String url) Set JDBC connection URL
RiverSource	RiverSource.setUser(String user) Set the user authentication

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

Modifier and Type	Method and Description
RiverContext	RiverContext.setRiverSource(RiverSource riverSource) Set river source

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

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

Modifier and Type	Class and Description
class	ColumnRiverSource<RC extends ColumnRiverContext> River source implementation for the 'column' strategy

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

Modifier and Type	Method and Description
protected ColumnRiverContext	ColumnRiverFlow.fillRiverContext(ColumnRiverContext riverContext, RiverState state, RiverSource riverSource, RiverMouth riverMouth)

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

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

Modifier and Type	Class and Description
class	SimpleRiverSource<RC extends SimpleRiverContext> Simple river source implementation.

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

Modifier and Type	Method and Description
protected RiverSource	SimpleRiverFlow.createRiverSource(Map<String,Object> params)
RiverSource	SimpleRiverSource.executeUpdate(PreparedStatement statement) Execute prepared update statement
RiverSource	SimpleRiverSource.executeUpdate(Statement statement, String sql) Execute prepared update statement
RiverSource	SimpleRiverContext.getRiverSource()

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

Modifier and Type	Method and Description
protected RC	SimpleRiverFlow.fillRiverContext(RC riverContext, RiverState state, RiverSource riverSource, RiverMouth riverMouth)
SimpleRiverContext	SimpleRiverContext.setRiverSource(RiverSource source)