Package org.apache.beam.sdk.io.mqtt

Class MqttRecord

java.lang.Object

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

@DefaultSchema(AutoValueSchema.class)
public abstract class MqttRecord
extends Object

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

Constructor Summary

Constructors

Constructor	Description
MqttRecord()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Details

MqttRecord

public MqttRecord()

Method Details

getTopic

public abstract String getTopic()

getPayload

public abstract byte[] getPayload()