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