Package | Description |
---|---|
backtype.storm.testing | |
org.apache.storm.hbase.bolt.mapper | |
org.apache.storm.hbase.trident.state |
Modifier and Type | Method and Description |
---|---|
void |
MockedSources.addMockData(String spoutId,
String streamId,
Values... valueses)
add mock data for the spout.
|
void |
MockedSources.addMockData(String spoutId,
Values... valueses) |
Modifier and Type | Method and Description |
---|---|
List<Values> |
HBaseValueMapper.toValues(ITuple input,
org.apache.hadoop.hbase.client.Result result) |
Modifier and Type | Method and Description |
---|---|
List<List<Values>> |
HBaseQuery.batchRetrieve(HBaseState hBaseState,
List<TridentTuple> tridentTuples) |
List<List<Values>> |
HBaseState.batchRetrieve(List<TridentTuple> tridentTuples) |
Modifier and Type | Method and Description |
---|---|
void |
HBaseQuery.execute(TridentTuple tuples,
List<Values> values,
TridentCollector tridentCollector) |
Copyright © 2016 The Apache Software Foundation. All Rights Reserved.