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 and 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 Detail

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.