@Experimental(value=SOURCE_SINK)

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

Transforms for reading and writing from MQTT.

See: Description

Class Summary

Class	Description
MqttIO	An unbounded source for MQTT broker.
MqttIO.ConnectionConfiguration	A POJO describing a MQTT connection.
MqttIO.Read	A PTransform to read from a MQTT broker.
MqttIO.Write	A PTransform to write and send a message to a MQTT server.

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

Transforms for reading and writing from MQTT.