org.apache.storm.rocketmq.common.mapper

Interface TupleToMessageMapper

All Superinterfaces:

Serializable

All Known Implementing Classes:

FieldNameBasedTupleToMessageMapper

public interface TupleToMessageMapper
extends Serializable

Interface defining a mapping from storm tuple to rocketmq key and message.

Method Summary

Modifier and Type	Method and Description
String	getKeyFromTuple(ITuple tuple)
byte[]	getValueFromTuple(ITuple tuple)

Method Detail

getKeyFromTuple

String getKeyFromTuple(ITuple tuple)

getValueFromTuple

byte[] getValueFromTuple(ITuple tuple)