Package org.apache.storm.elasticsearch.common

Interface EsTupleMapper

All Superinterfaces:
Serializable
All Known Implementing Classes:
DefaultEsTupleMapper
public interface EsTupleMapper extends Serializable
TupleMapper defines how to extract source, index, type, and id from tuple for ElasticSearch.

  • Method Details

    • getSource

      String getSource(ITuple tuple)
      Extracts source from tuple.
      Parameters:
      tuple - source tuple
      Returns:
      source

    • getIndex

      String getIndex(ITuple tuple)
      Extracts index from tuple.
      Parameters:
      tuple - source tuple
      Returns:
      index

    • getType

      String getType(ITuple tuple)
      Extracts type from tuple.
      Parameters:
      tuple - source tuple
      Returns:
      type

    • getId

      String getId(ITuple tuple)
      Extracts id from tuple.
      Parameters:
      tuple - source tuple
      Returns:
      id

    • getParams

      Map<String,String> getParams(ITuple tuple, Map<String,String> defaultValue)
      Extracts params from tuple if available.
      Parameters:
      tuple - source tuple
      defaultValue - value to return if params are missing
      Returns:
      params