public class EsUpdater extends BaseStateUpdater<org.apache.storm.elasticsearch.trident.EsState>
| Constructor and Description |
|---|
EsUpdater() |
| Modifier and Type | Method and Description |
|---|---|
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.
|
cleanup, preparepublic 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.
Copyright © 2021 The Apache Software Foundation. All rights reserved.