org.apache.storm.opentsdb.trident

Class OpenTsdbStateFactory

java.lang.Object

org.apache.storm.opentsdb.trident.OpenTsdbStateFactory

All Implemented Interfaces:

Serializable, StateFactory

public class OpenTsdbStateFactory
extends Object
implements StateFactory

Trident StateFactory implementation for OpenTSDB.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
OpenTsdbStateFactory(OpenTsdbClient.Builder builder, List<? extends ITupleOpenTsdbDatapointMapper> tridentTupleOpenTsdbDatapointMappers)

Method Summary

Modifier and Type	Method and Description
State	makeState(Map<String,Object> conf, IMetricsContext metrics, int partitionIndex, int numPartitions)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OpenTsdbStateFactory

public OpenTsdbStateFactory(OpenTsdbClient.Builder builder,
                            List<? extends ITupleOpenTsdbDatapointMapper> tridentTupleOpenTsdbDatapointMappers)

Method Detail

makeState

public State makeState(Map<String,Object> conf,
                       IMetricsContext metrics,
                       int partitionIndex,
                       int numPartitions)

Specified by:

makeState in interface StateFactory