org.apache.beam.sdk.io.mqtt

Class MqttRecord

java.lang.Object

org.apache.beam.sdk.io.mqtt.MqttRecord

@DefaultSchema(value=AutoValueSchema.class)
public abstract class MqttRecord
extends java.lang.Object

A container class for MQTT message metadata, including the topic name and payload.

Constructor Summary

Constructors

Constructor and Description
MqttRecord()

Method Summary

Modifier and Type	Method and Description
abstract byte[]	getPayload()
abstract java.lang.String	getTopic()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MqttRecord

public MqttRecord()

Method Detail

getTopic

public abstract java.lang.String getTopic()

getPayload

public abstract byte[] getPayload()