Package | Description |
---|---|
org.apache.storm.jdbc.common | |
org.apache.storm.jdbc.mapper |
Modifier and Type | Method and Description |
---|---|
List<Column> |
JdbcClient.getColumnSchema(String tableName) |
List<List<Column>> |
JdbcClient.select(String sqlQuery,
List<Column> queryParams) |
Modifier and Type | Method and Description |
---|---|
void |
JdbcClient.executeInsertQuery(String query,
List<List<Column>> columnLists) |
void |
JdbcClient.insert(String tableName,
List<List<Column>> columnLists) |
List<List<Column>> |
JdbcClient.select(String sqlQuery,
List<Column> queryParams) |
Modifier and Type | Method and Description |
---|---|
List<Column> |
SimpleJdbcMapper.getColumns(ITuple tuple) |
List<Column> |
JdbcMapper.getColumns(ITuple tuple)
Get columns.
|
Modifier and Type | Method and Description |
---|---|
List<Values> |
JdbcLookupMapper.toTuple(ITuple input,
List<Column> columns)
Converts a DB row to a list of storm values that can be emitted.
|
List<Values> |
SimpleJdbcLookupMapper.toTuple(ITuple input,
List<Column> columns) |
Constructor and Description |
---|
SimpleJdbcLookupMapper(Fields outputFields,
List<Column> queryColumns) |
SimpleJdbcMapper(List<Column> schemaColumns) |
Copyright © 2019 The Apache Software Foundation. All rights reserved.