org.apache.storm.kinesis.spout

Interface RecordToTupleMapper

public interface RecordToTupleMapper

Method Summary

Modifier and Type	Method and Description
Fields	getOutputFields()
List<Object>	getTuple(com.amazonaws.services.kinesis.model.Record record)

Method Detail

getOutputFields

Fields getOutputFields()

Returns:

names of fields in the emitted tuple

getTuple

List<Object> getTuple(com.amazonaws.services.kinesis.model.Record record)

Parameters:

record - kinesis record

Returns:

storm tuple to be emitted for this record, null if no tuple should be emitted