Package org.apache.storm.jdbc.mapper
Interface JdbcLookupMapper
- All Superinterfaces:
JdbcMapper
,Serializable
- All Known Implementing Classes:
SimpleJdbcLookupMapper
-
Method Summary
Modifier and TypeMethodDescriptionvoid
declareOutputFields
(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 interface org.apache.storm.jdbc.mapper.JdbcMapper
getColumns
-
Method Details
-
toTuple
Converts 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.- 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.
-
declareOutputFields
declare what are the fields that this code will output.
-