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)

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)

Specified by:

getColumns in interface JdbcMapper

Returns:

list of columns that represents one row in a DB table.