Class SimpleJdbcMapper

java.lang.Object
org.apache.storm.jdbc.mapper.SimpleJdbcMapper
All Implemented Interfaces:
Serializable, JdbcMapper
Direct Known Subclasses:
SimpleJdbcLookupMapper

public class SimpleJdbcMapper extends Object implements JdbcMapper
See Also:
  • Constructor Details

    • SimpleJdbcMapper

      public SimpleJdbcMapper(String tableName, ConnectionProvider connectionProvider)
    • SimpleJdbcMapper

      public SimpleJdbcMapper(List<Column> schemaColumns)
  • Method Details

    • getColumns

      public List<Column> getColumns(ITuple tuple)
      Description copied from interface: JdbcMapper
      Get columns.
      Specified by:
      getColumns in interface JdbcMapper
      Returns:
      list of columns that represents one row in a DB table.