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

Class KinesisIO.RecordAggregation.Builder

java.lang.Object

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

Enclosing class:

KinesisIO.RecordAggregation

public abstract static class KinesisIO.RecordAggregation.Builder
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
KinesisIO.RecordAggregation	build()
abstract KinesisIO.RecordAggregation.Builder	maxBufferedTime(Duration interval) Buffer timeout for user records.
abstract KinesisIO.RecordAggregation.Builder	maxBytes(int bytes) Max bytes per aggregated record.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

maxBytes

public abstract KinesisIO.RecordAggregation.Builder maxBytes(int bytes)

Max bytes per aggregated record.

maxBufferedTime

public abstract KinesisIO.RecordAggregation.Builder maxBufferedTime(Duration interval)

Buffer timeout for user records.

Note: This is only attempted on a best effort basis. In case request latency is too high, timeouts can be delayed.

build

public KinesisIO.RecordAggregation build()