public interface MongoLookupMapper extends Serializable
| 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,
org.bson.Document doc)
Converts a Mongo document to a list of storm values that can be emitted.
|
List<Values> toTuple(ITuple input, org.bson.Document doc)
Converts a Mongo document to a list of storm values that can be emitted. This is done to allow a single storm input tuple and a single Mongo document to result in multiple output values.
input - the input tuple.doc - the mongo documentvoid declareOutputFields(OutputFieldsDeclarer declarer)
declare what are the fields that this code will output.
declarer - OutputFieldsDeclarerCopyright © 2021 The Apache Software Foundation. All rights reserved.