Package org.apache.storm.elasticsearch

Interface EsLookupResultOutput

All Superinterfaces:
Serializable
All Known Implementing Classes:
DefaultEsLookupResultOutput
public interface EsLookupResultOutput extends Serializable
The adapter to convert the results fetched from Elasticsearch to values.
Since:
0.11

  • Method Summary

    Modifier and Type
    Method
    Description
    Fields
    fields()
    Fields to be declared for output.
    Collection<Values>
    toValues(org.elasticsearch.client.Response response)
    Convert Elasticsearch response to a collection of Values.

  • Method Details

    • toValues

      Collection<Values> toValues(org.elasticsearch.client.Response response)
      Convert Elasticsearch response to a collection of Values.
      Returns:
      collection of values to emit.

    • fields

      Fields fields()
      Fields to be declared for output.
      Returns:
      output fields to declare.