| 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.
|