org.apache.storm.opentsdb.trident

Class OpenTsdbState

java.lang.Object

org.apache.storm.opentsdb.trident.OpenTsdbState

All Implemented Interfaces:

State

public class OpenTsdbState
extends Object
implements State

Trident State implementation for OpenTSDB.

Constructor Summary

Constructors

Constructor and Description
OpenTsdbState(Map<String,Object> conf, OpenTsdbClient.Builder openTsdbClientBuilder, Iterable<? extends ITupleOpenTsdbDatapointMapper> tupleMetricPointMappers)

Method Summary

Modifier and Type	Method and Description
void	beginCommit(Long txid)
void	commit(Long txid)
void	prepare()
void	update(List<TridentTuple> tridentTuples, TridentCollector collector)

Methods inherited from class java.lang.Object

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

Constructor Detail

OpenTsdbState

public OpenTsdbState(Map<String,Object> conf,
                     OpenTsdbClient.Builder openTsdbClientBuilder,
                     Iterable<? extends ITupleOpenTsdbDatapointMapper> tupleMetricPointMappers)

Method Detail

prepare

public void prepare()

beginCommit

public void beginCommit(Long txid)

Specified by:

beginCommit in interface State

commit

public void commit(Long txid)

Specified by:

commit in interface State

update

public void update(List<TridentTuple> tridentTuples,
                   TridentCollector collector)