Package org.apache.storm.jdbc.mapper
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:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description SimpleJdbcMapper(String tableName, ConnectionProvider connectionProvider)
SimpleJdbcMapper(List<Column> schemaColumns)
-
-
-
Constructor Detail
-
SimpleJdbcMapper
public SimpleJdbcMapper(String tableName, ConnectionProvider connectionProvider)
-
-
Method Detail
-
getColumns
public List<Column> getColumns(ITuple tuple)
Description copied from interface:JdbcMapper
Get columns.- Specified by:
getColumns
in interfaceJdbcMapper
- Returns:
- list of columns that represents one row in a DB table.
-
-