Package org.apache.beam.sdk.io.gcp.pubsub

Class ExternalWrite

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsub.ExternalWrite

All Implemented Interfaces:

ExternalTransformRegistrar

@AutoService(ExternalTransformRegistrar.class)
public final class ExternalWrite
extends Object
implements ExternalTransformRegistrar

Exposes PubsubIO.Write as an external transform for cross-language usage.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ExternalWrite.Configuration	Parameters class to expose the transform to an external SDK.
static class	ExternalWrite.ParsePubsubMessageProtoAsPayloadFromWindowedValue
static class	ExternalWrite.WriteBuilder

Field Summary

Fields

Modifier and Type	Field	Description
static final String	URN

Constructor Summary

Constructors

Constructor	Description
ExternalWrite()

Method Summary

Modifier and Type	Method	Description
Map<String,Class<? extends ExternalTransformBuilder<?,?,?>>>	knownBuilders()	A mapping from URN to an ExternalTransformBuilder class.

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

knownBuilderInstances

Field Details

URN

public static final String URN

See Also:

• Constant Field Values

Constructor Details

ExternalWrite

public ExternalWrite()

Method Details

knownBuilders

public Map<String,Class<? extends ExternalTransformBuilder<?,?,?>>> knownBuilders()

Description copied from interface: ExternalTransformRegistrar

A mapping from URN to an ExternalTransformBuilder class.

Specified by:

knownBuilders in interface ExternalTransformRegistrar