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 Summary
Constructors -
Method Summary
Modifier 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.SimpleJdbcMapper
getColumnsMethods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.apache.storm.jdbc.mapper.JdbcMapper
getColumns
-
Constructor Details
-
SimpleJdbcLookupMapper
-
-
Method Details
-
toTuple
Description 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 interfaceJdbcLookupMapper- 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
Description copied from interface:JdbcLookupMapperdeclare what are the fields that this code will output.- Specified by:
declareOutputFieldsin interfaceJdbcLookupMapper
-