Aggregate

interface Aggregate

Represents a batch or aggregation of records to be loaded via bulk operations.

Implementations of this interface accumulate records into a batch that will be efficiently loaded into the destination using bulk operations. The CDK automatically handles when to trigger flush based on AggregatePublishingConfig settings.

Functions

Link copied to clipboard
abstract fun accept(record: RecordDTO)

Accepts a record to be added to this aggregate.

Link copied to clipboard
abstract suspend fun flush()

Finalizes this aggregate and loads it into the destination.