Package org.apache.storm.elasticsearch
Class DefaultEsLookupResultOutput
java.lang.Object
org.apache.storm.elasticsearch.DefaultEsLookupResultOutput
- All Implemented Interfaces:
Serializable
,EsLookupResultOutput
Default implementation of
EsLookupResultOutput
.
Outputs the index, type, id and source as strings.- See Also:
-
Constructor Summary
ConstructorDescriptionDefaultEsLookupResultOutput
(com.fasterxml.jackson.databind.ObjectMapper objectMapper) -
Method Summary
-
Constructor Details
-
DefaultEsLookupResultOutput
public DefaultEsLookupResultOutput(com.fasterxml.jackson.databind.ObjectMapper objectMapper)
-
-
Method Details
-
toValues
Description copied from interface:EsLookupResultOutput
Convert Elasticsearch response to a collection ofValues
.- Specified by:
toValues
in interfaceEsLookupResultOutput
- Returns:
- collection of values to emit.
-
fields
Description copied from interface:EsLookupResultOutput
Fields
to be declared for output.- Specified by:
fields
in interfaceEsLookupResultOutput
- Returns:
- output fields to declare.
-