org.apache.storm.elasticsearch

Interface EsLookupResultOutput

All Superinterfaces:

Serializable

All Known Implementing Classes:

DefaultEsLookupResultOutput

public interface EsLookupResultOutput
extends Serializable

Since:

0.11 The adapter to convert the results fetched from Elasticsearch to values.

Method Summary

Modifier and Type	Method and Description
Fields	fields()
Collection<Values>	toValues(org.elasticsearch.client.Response response)

Method Detail

toValues

Collection<Values> toValues(org.elasticsearch.client.Response response)

Returns:

collection of values to emit.

fields

Fields fields()

Returns:

output fields to declare.