public class SimpleJdbcLookupMapper extends SimpleJdbcMapper implements JdbcLookupMapper
| Constructor and Description |
|---|
SimpleJdbcLookupMapper(Fields outputFields,
List<Column> queryColumns) |
| Modifier and Type | Method and Description |
|---|---|
void |
declareOutputFields(OutputFieldsDeclarer declarer)
declare what are the fields that this code will output.
|
List<Values> |
toTuple(ITuple input,
List<Column> columns)
Converts a DB row to a list of storm values that can be emitted.
|
getColumnsclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitgetColumnspublic List<Values> toTuple(ITuple input, List<Column> columns)
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.
toTuple in interface JdbcLookupMapperinput - the input tuple.columns - list of columns that represents a rowpublic void declareOutputFields(OutputFieldsDeclarer declarer)
JdbcLookupMapperdeclare what are the fields that this code will output.
declareOutputFields in interface JdbcLookupMapperCopyright © 2021 The Apache Software Foundation. All rights reserved.