Class EsUpdater

java.lang.Object
org.apache.storm.trident.operation.BaseOperation
org.apache.storm.trident.state.BaseStateUpdater<org.apache.storm.elasticsearch.trident.EsState>
org.apache.storm.elasticsearch.trident.EsUpdater
All Implemented Interfaces:
Serializable, Operation, StateUpdater<org.apache.storm.elasticsearch.trident.EsState>

public class EsUpdater extends BaseStateUpdater<org.apache.storm.elasticsearch.trident.EsState>
See Also:
  • Constructor Details

    • EsUpdater

      public EsUpdater()
  • Method Details

    • updateState

      public void updateState(org.apache.storm.elasticsearch.trident.EsState state, List<TridentTuple> tuples, TridentCollector collector)
      Each tuple should have relevant fields (source, index, type, id) for EsState's tupleMapper to extract ES document.