org.apache.storm.kinesis.spout

Interface RecordToTupleMapper

public interface RecordToTupleMapper

Method Summary

Modifier and Type	Method and Description
Fields	getOutputFields() Retrieve the names of fields.
List<Object>	getTuple(com.amazonaws.services.kinesis.model.Record record) Retrieve the tuple.

Method Detail

getOutputFields

Fields getOutputFields()

Retrieve the names of fields.

Returns:

names of fields in the emitted tuple

getTuple

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

Retrieve the tuple.

Parameters:

record - kinesis record

Returns:

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