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)

Method Summary

Modifier and Type	Method	Description
List<Column>	getColumns(ITuple tuple)	Get columns.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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.