Class EsStateFactory
java.lang.Object
org.apache.storm.elasticsearch.trident.EsStateFactory
- All Implemented Interfaces:
Serializable
,StateFactory
StateFactory for providing EsState.
- Since:
- 0.11
- See Also:
-
Constructor Summary
ConstructorDescriptionEsStateFactory
(EsConfig esConfig, EsTupleMapper tupleMapper) EsStateFactory constructor. -
Method Summary
-
Constructor Details
-
EsStateFactory
EsStateFactory constructor.- Parameters:
esConfig
- Elasticsearch configuration containing node addresses and cluster nameEsConfig
tupleMapper
- Tuple to ES document mapperEsTupleMapper
-
-
Method Details
-
makeState
public State makeState(Map<String, Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions) - Specified by:
makeState
in interfaceStateFactory
-