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

package org.apache.beam.sdk.io.mqtt

Transforms for reading and writing from MQTT.

Related Packages

Package	Description
org.apache.beam.sdk.io	Defines transforms for reading and writing common storage formats, including invalid reference org.apache.beam.sdk.io.AvroIO , and TextIO.

Classes

Class	Description
MqttIO	An unbounded source for MQTT broker.
MqttIO.ConnectionConfiguration	A POJO describing a MQTT connection.
MqttIO.Read<T>	A PTransform to read from a MQTT broker.
MqttIO.Write<InputT>	A PTransform to write and send a message to a MQTT server.
MqttRecord	A container class for MQTT message metadata, including the topic name and payload.