| 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