| 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 © 2022 The Apache Software Foundation. All rights reserved.