public class ByteArrayMessageMapper extends Object implements MqttMessageMapper
| Constructor and Description |
|---|
ByteArrayMessageMapper() |
| Modifier and Type | Method and Description |
|---|---|
Fields |
outputFields()
Returns the list of output fields this Mapper produces.
|
Values |
toValues(MqttMessage message)
Convert a
MqttMessage to a set of Values that can be emitted as a Storm Tuple. |
public Values toValues(MqttMessage message)
MqttMessageMapperConvert a MqttMessage to a set of Values that can be emitted as a Storm Tuple.
toValues in interface MqttMessageMappermessage - An MQTT Message.public Fields outputFields()
MqttMessageMapperReturns the list of output fields this Mapper produces.
outputFields in interface MqttMessageMapperCopyright © 2021 The Apache Software Foundation. All rights reserved.