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