Package | Description |
---|---|
org.xbib.elasticsearch.plugin.jdbc.util | |
org.xbib.elasticsearch.river.jdbc | |
org.xbib.elasticsearch.river.jdbc.strategy.simple |
Modifier and Type | Method and Description |
---|---|
SQLCommand |
SQLCommand.setCallable(boolean callable) |
SQLCommand |
SQLCommand.setParameters(List<Object> params) |
SQLCommand |
SQLCommand.setSQL(String sql) |
Modifier and Type | Method and Description |
---|---|
static List<SQLCommand> |
SQLCommand.parse(Map<String,Object> settings) |
Modifier and Type | Method and Description |
---|---|
void |
RiverSource.afterRows(SQLCommand command,
ResultSet results,
KeyValueStreamListener listener)
After the result set is processed, this method is called.
|
void |
RiverSource.beforeRows(SQLCommand command,
ResultSet results,
KeyValueStreamListener listener)
This routine is executed before the result set is evaluated
|
boolean |
RiverSource.nextRow(SQLCommand command,
ResultSet results,
KeyValueStreamListener listener)
Action for the next row of the result set to be processed
|
Modifier and Type | Method and Description |
---|---|
RiverContext |
RiverContext.setStatements(List<SQLCommand> sql)
Set the list of SQL statements
|
Modifier and Type | Method and Description |
---|---|
List<SQLCommand> |
SimpleRiverContext.getStatements() |
Modifier and Type | Method and Description |
---|---|
void |
SimpleRiverSource.afterRows(SQLCommand command,
ResultSet results,
KeyValueStreamListener listener)
After the rows keys and values, let the listener know about the end of
the result set.
|
void |
SimpleRiverSource.beforeRows(SQLCommand command,
ResultSet results,
KeyValueStreamListener listener)
Before rows are read, let the KeyValueStreamListener know about the keys.
|
protected void |
SimpleRiverSource.merge(SQLCommand command,
ResultSet results,
KeyValueStreamListener listener)
Merge key/values from JDBC result set
|
boolean |
SimpleRiverSource.nextRow(SQLCommand command,
ResultSet results,
KeyValueStreamListener listener)
Get next row and prepare the values for processing.
|
Modifier and Type | Method and Description |
---|---|
SimpleRiverContext |
SimpleRiverContext.setStatements(List<SQLCommand> sql) |
elasticsearch-river-jdbc