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

Class KinesisIO.RecordAggregation

java.lang.Object

org.apache.beam.sdk.io.aws2.kinesis.KinesisIO.RecordAggregation

All Implemented Interfaces:

java.io.Serializable

Enclosing class:

KinesisIO

public abstract static class KinesisIO.RecordAggregation
extends java.lang.Object
implements java.io.Serializable

Configuration of Kinesis record aggregation.

Record aggregation is compatible with KPL/KCL and helps to better max out API limits.

See Also:

KPL Concepts: aggregation, Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KinesisIO.RecordAggregation.Builder

Constructor Summary

Constructors

Constructor and Description
RecordAggregation()

Method Summary

Modifier and Type	Method and Description
static KinesisIO.RecordAggregation.Builder	builder()

Methods inherited from class java.lang.Object

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

Constructor Detail

RecordAggregation

public RecordAggregation()

Method Detail

builder

public static KinesisIO.RecordAggregation.Builder builder()