Package org.apache.storm.jdbc.mapper
Class SimpleJdbcLookupMapper
java.lang.Object
org.apache.storm.jdbc.mapper.SimpleJdbcMapper
org.apache.storm.jdbc.mapper.SimpleJdbcLookupMapper
- All Implemented Interfaces:
- Serializable,- JdbcLookupMapper,- JdbcMapper
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionvoiddeclareOutputFields(OutputFieldsDeclarer declarer) declare what are the fields that this code will output.Converts a DB row to a list of storm values that can be emitted.Methods inherited from class org.apache.storm.jdbc.mapper.SimpleJdbcMappergetColumnsMethods inherited from class java.lang.Objectclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.jdbc.mapper.JdbcMappergetColumns
- 
Constructor Details- 
SimpleJdbcLookupMapper
 
- 
- 
Method Details- 
toTupleDescription copied from interface:JdbcLookupMapperConverts a DB row to a list of storm values that can be emitted. This is done to allow a single storm input tuple and a single DB row to result in multiple output values.- Specified by:
- toTuplein interface- JdbcLookupMapper
- Parameters:
- input- the input tuple.
- columns- list of columns that represents a row
- Returns:
- a List of storm values that can be emitted. Each item in list is emitted as an output tuple.
 
- 
declareOutputFieldsDescription copied from interface:JdbcLookupMapperdeclare what are the fields that this code will output.- Specified by:
- declareOutputFieldsin interface- JdbcLookupMapper
 
 
-