org.apache.storm.hbase.bolt.mapper

Interface HBaseValueMapper

All Superinterfaces:

Serializable

All Known Implementing Classes:

WordCountValueMapper

public interface HBaseValueMapper
extends Serializable

Method Summary

Modifier and Type	Method and Description
void	declareOutputFields(OutputFieldsDeclarer declarer) declares the output fields for the lookup bolt.
List<Values>	toValues(ITuple input, org.apache.hadoop.hbase.client.Result result) Map to values.

Method Detail

toValues

List<Values> toValues(ITuple input,
                      org.apache.hadoop.hbase.client.Result result)
               throws Exception

Map to values.

Parameters:

input - tuple

result - HBase lookup result instance

Returns:

list of values that should be emitted by the lookup bolt

Throws:

Exception

declareOutputFields

void declareOutputFields(OutputFieldsDeclarer declarer)

declares the output fields for the lookup bolt.