Modifier and Type | Class and Description |
---|---|
static class |
CassandraState.Options |
Modifier | Constructor and Description |
---|---|
protected |
CassandraState(Map<String,Object> conf,
CassandraState.Options options) |
Modifier and Type | Method and Description |
---|---|
List<List<Values>> |
batchRetrieve(List<TridentTuple> tridentTuples) |
void |
beginCommit(Long txid) |
void |
cleanup() |
void |
commit(Long txid) |
void |
prepare() |
void |
updateState(List<TridentTuple> tuples,
TridentCollector collector) |
protected CassandraState(Map<String,Object> conf, CassandraState.Options options)
public void beginCommit(Long txid)
beginCommit
in interface State
public void prepare()
public void cleanup()
public void updateState(List<TridentTuple> tuples, TridentCollector collector)
public List<List<Values>> batchRetrieve(List<TridentTuple> tridentTuples)
Copyright © 2023 The Apache Software Foundation. All rights reserved.