Package org.apache.beam.sdk.io.aws2.kinesis

Class KinesisTransformRegistrar

java.lang.Object

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

All Implemented Interfaces:

ExternalTransformRegistrar

@AutoService(ExternalTransformRegistrar.class)
public class KinesisTransformRegistrar
extends 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	Description
static class	KinesisTransformRegistrar.KinesisReadToBytes
static class	KinesisTransformRegistrar.ReadDataBuilder
static class	KinesisTransformRegistrar.WriteBuilder

Field Summary

Fields

Modifier and Type	Field	Description
static final String	READ_DATA_URN
static final String	WRITE_URN

Constructor Summary

Constructors

Constructor	Description
KinesisTransformRegistrar()

Method Summary

Modifier and Type	Method	Description
Map<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 Details

WRITE_URN

public static final String WRITE_URN

See Also:

• Constant Field Values

READ_DATA_URN

public static final String READ_DATA_URN

See Also:

• Constant Field Values

Constructor Details

KinesisTransformRegistrar

public KinesisTransformRegistrar()

Method Details

knownBuilderInstances

public Map<String,ExternalTransformBuilder<?,?,?>> knownBuilderInstances()

Description copied from interface: ExternalTransformRegistrar

A mapping from URN to an ExternalTransformBuilder instance.

Specified by:

knownBuilderInstances in interface ExternalTransformRegistrar