| Constructor and Description |
|---|
OpenTsdbState(Map<String,Object> conf,
OpenTsdbClient.Builder openTsdbClientBuilder,
Iterable<? extends ITupleOpenTsdbDatapointMapper> tupleMetricPointMappers) |
| Modifier and Type | Method and Description |
|---|---|
void |
beginCommit(Long txid) |
void |
commit(Long txid) |
void |
prepare() |
void |
update(List<TridentTuple> tridentTuples,
TridentCollector collector) |
public OpenTsdbState(Map<String,Object> conf, OpenTsdbClient.Builder openTsdbClientBuilder, Iterable<? extends ITupleOpenTsdbDatapointMapper> tupleMetricPointMappers)
public void prepare()
public void beginCommit(Long txid)
beginCommit in interface Statepublic void update(List<TridentTuple> tridentTuples, TridentCollector collector)
Copyright © 2021 The Apache Software Foundation. All rights reserved.