public abstract static class KinesisIO.RecordAggregation.Builder
extends java.lang.Object
Constructor and Description |
---|
Builder() |
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.
|
public abstract KinesisIO.RecordAggregation.Builder maxBytes(int bytes)
public abstract KinesisIO.RecordAggregation.Builder maxBufferedTime(Duration interval)
Note: This is only attempted on a best effort basis. In case request latency is too high, timeouts can be delayed.
public KinesisIO.RecordAggregation build()