org.apache.beam.sdk.io.kinesis

Class KinesisTransformRegistrar

java.lang.Object

org.apache.beam.sdk.io.kinesis.KinesisTransformRegistrar

All Implemented Interfaces:

ExternalTransformRegistrar

@Experimental(value=PORTABILITY)
 @AutoService(value=ExternalTransformRegistrar.class)
public class KinesisTransformRegistrar
extends java.lang.Object
implements ExternalTransformRegistrar

Exposes KinesisIO.Write and KinesisIO.Read as an external transform for cross-language usage.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KinesisTransformRegistrar.ReadDataBuilder
static class	KinesisTransformRegistrar.WriteBuilder

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	READ_DATA_URN
static java.lang.String	WRITE_URN

Constructor Summary

Constructors

Constructor and Description
KinesisTransformRegistrar()

Method Summary

Modifier and Type	Method and Description
java.util.Map<java.lang.String,ExternalTransformBuilder<?,?,?>>	knownBuilderInstances() A mapping from URN to an ExternalTransformBuilder instance.

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

knownBuilders

Field Detail

WRITE_URN

public static final java.lang.String WRITE_URN

See Also:

Constant Field Values

READ_DATA_URN

public static final java.lang.String READ_DATA_URN

See Also:

Constant Field Values

Constructor Detail

KinesisTransformRegistrar

public KinesisTransformRegistrar()

Method Detail

knownBuilderInstances

public java.util.Map<java.lang.String,ExternalTransformBuilder<?,?,?>> knownBuilderInstances()

Description copied from interface: ExternalTransformRegistrar

A mapping from URN to an ExternalTransformBuilder instance.

Specified by:

knownBuilderInstances in interface ExternalTransformRegistrar