| 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.