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

Class MqttReadSchemaTransformProvider.ReadConfiguration

java.lang.Object

org.apache.beam.sdk.io.mqtt.MqttReadSchemaTransformProvider.ReadConfiguration

All Implemented Interfaces:

Serializable

Enclosing class:

MqttReadSchemaTransformProvider

@DefaultSchema(AutoValueSchema.class)
public abstract static class MqttReadSchemaTransformProvider.ReadConfiguration
extends Object
implements Serializable

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MqttReadSchemaTransformProvider.ReadConfiguration.Builder

Constructor Summary

Constructors

Constructor	Description
ReadConfiguration()

Method Summary

Modifier and Type	Method	Description
static MqttReadSchemaTransformProvider.ReadConfiguration.Builder	builder()
abstract MqttIO.ConnectionConfiguration	getConnectionConfiguration()
abstract Long	getMaxNumRecords()
abstract Long	getMaxReadTimeSeconds()

Methods inherited from class java.lang.Object

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

Constructor Details

ReadConfiguration

public ReadConfiguration()

Method Details

builder

public static MqttReadSchemaTransformProvider.ReadConfiguration.Builder builder()

getConnectionConfiguration

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

getMaxNumRecords

@SchemaFieldDescription("The max number of records to receive. Setting this will result in a bounded PCollection.")
@Nullable
public abstract Long getMaxNumRecords()

getMaxReadTimeSeconds

@SchemaFieldDescription("The maximum time for this source to read messages. Setting this will result in a bounded PCollection.")
@Nullable
public abstract Long getMaxReadTimeSeconds()