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 and Description
SimpleJdbcMapper(List<Column> schemaColumns)
SimpleJdbcMapper(String tableName, ConnectionProvider connectionProvider)

Method Summary

Modifier and Type	Method and 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 Detail

SimpleJdbcMapper

public SimpleJdbcMapper(String tableName,
                        ConnectionProvider connectionProvider)

SimpleJdbcMapper

public SimpleJdbcMapper(List<Column> schemaColumns)

Method Detail

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.