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(value=ExternalTransformRegistrar.class)
public final class ExternalWrite
extends java.lang.Object
implements ExternalTransformRegistrar

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

Nested Class Summary

Nested Classes

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

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	URN

Constructor Summary

Constructors

Constructor and Description
ExternalWrite()

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,java.lang.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 Detail

URN

public static final java.lang.String URN

See Also:

Constant Field Values

Constructor Detail

ExternalWrite

public ExternalWrite()

Method Detail

knownBuilders

public java.util.Map<java.lang.String,java.lang.Class<? extends ExternalTransformBuilder<?,?,?>>> knownBuilders()

Description copied from interface: ExternalTransformRegistrar

A mapping from URN to an ExternalTransformBuilder class.

Specified by:

knownBuilders in interface ExternalTransformRegistrar