Package 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:

Serializable

Enclosing class:

KinesisIO

public abstract static class KinesisIO.RecordAggregation
extends Object
implements 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	Description
static class	KinesisIO.RecordAggregation.Builder

Constructor Summary

Constructors

Constructor	Description
RecordAggregation()

Method Summary

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

RecordAggregation

public RecordAggregation()

Method Details

builder

public static KinesisIO.RecordAggregation.Builder builder()