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

Class MqttWriteSchemaTransformProvider.WriteConfiguration

java.lang.Object

org.apache.beam.sdk.io.mqtt.MqttWriteSchemaTransformProvider.WriteConfiguration

All Implemented Interfaces:

Serializable

Enclosing class:

MqttWriteSchemaTransformProvider

@DefaultSchema(AutoValueSchema.class)
public abstract static class MqttWriteSchemaTransformProvider.WriteConfiguration
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MqttWriteSchemaTransformProvider.WriteConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
WriteConfiguration()

Method Summary

Modifier and Type	Method	Description
static MqttWriteSchemaTransformProvider.WriteConfiguration.Builder	builder()
abstract MqttIO.ConnectionConfiguration	getConnectionConfiguration()
abstract Boolean	getRetained()

Methods inherited from class java.lang.Object

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

Constructor Details

WriteConfiguration

public WriteConfiguration()

Method Details

builder

public static MqttWriteSchemaTransformProvider.WriteConfiguration.Builder builder()

getConnectionConfiguration

@SchemaFieldDescription("Configuration options to set up the MQTT connection.")
public abstract MqttIO.ConnectionConfiguration getConnectionConfiguration()

getRetained

@SchemaFieldDescription("Whether or not the publish message should be retained by the messaging engine. When a subscriber connects, it gets the latest retained message. Defaults to `False`, which will clear the retained message from the server.")
@Nullable
public abstract Boolean getRetained()