MqttWriteSchemaTransformProvider (Apache Beam 2.75.0)

java.lang.Object

org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider<MqttWriteSchemaTransformProvider.WriteConfiguration>

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

All Implemented Interfaces:: SchemaTransformProvider

@AutoService(SchemaTransformProvider.class) public class MqttWriteSchemaTransformProvider extends TypedSchemaTransformProvider<MqttWriteSchemaTransformProvider.WriteConfiguration>

Nested Class Summary

Nested Classes

Modifier and Type

Class

Description

static class

MqttWriteSchemaTransformProvider.WriteConfiguration
Constructor Summary

Constructors

Constructor

Description

MqttWriteSchemaTransformProvider()
Method Summary

Modifier and Type

Method

Description

String

description()

Returns a description regarding the SchemaTransform represented by the SchemaTransformProvider.

protected SchemaTransform

from(MqttWriteSchemaTransformProvider.WriteConfiguration configuration)

Produce a SchemaTransform from ConfigT.

String

identifier()

Returns an id that uniquely represents this transform.

Methods inherited from class org.apache.beam.sdk.schemas.transforms.TypedSchemaTransformProvider
configurationClass, configurationSchema, dependencies, from

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.sdk.schemas.transforms.SchemaTransformProvider
inputCollectionNames, outputCollectionNames

Constructor Details
- MqttWriteSchemaTransformProvider
  
  public MqttWriteSchemaTransformProvider()
Method Details
- identifier
  
  public String identifier()
  
  Description copied from interface: SchemaTransformProvider
  
  Returns an id that uniquely represents this transform.
- description
  
  public String description()
  
  Description copied from interface: SchemaTransformProvider
  
  Returns a description regarding the SchemaTransform represented by the SchemaTransformProvider. Please keep the language generic (i.e. not specific to any programming language). The description may be markdown formatted.
- from
  
  protected SchemaTransform from(MqttWriteSchemaTransformProvider.WriteConfiguration configuration)
  
  Description copied from class: TypedSchemaTransformProvider
  
  Produce a SchemaTransform from ConfigT. Can throw a InvalidConfigurationException or a InvalidSchemaException.
  
  Specified by:
  
  from in class TypedSchemaTransformProvider<MqttWriteSchemaTransformProvider.WriteConfiguration>