org.apache.beam.sdk.io.kinesis

Class KinesisTransformRegistrar.ReadDataBuilder

java.lang.Object

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

All Implemented Interfaces:

ExternalTransformBuilder<KinesisTransformRegistrar.ReadDataBuilder.Configuration,PBegin,PCollection<byte[]>>

Enclosing class:

KinesisTransformRegistrar

public static class KinesisTransformRegistrar.ReadDataBuilder
extends java.lang.Object
implements ExternalTransformBuilder<KinesisTransformRegistrar.ReadDataBuilder.Configuration,PBegin,PCollection<byte[]>>

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
ReadDataBuilder()

Method Summary

Modifier and Type	Method and Description
PTransform<PBegin,PCollection<byte[]>>	buildExternal(KinesisTransformRegistrar.ReadDataBuilder.Configuration configuration) Builds the transform after it has been configured.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ReadDataBuilder

public ReadDataBuilder()

Method Detail

buildExternal

public PTransform<PBegin,PCollection<byte[]>> buildExternal(KinesisTransformRegistrar.ReadDataBuilder.Configuration configuration)

Description copied from interface: ExternalTransformBuilder

Builds the transform after it has been configured.

Specified by:

buildExternal in interface ExternalTransformBuilder<KinesisTransformRegistrar.ReadDataBuilder.Configuration,PBegin,PCollection<byte[]>>