bulk-cdk-core-load/io.airbyte.cdk.load.dataflow.aggregate/Aggregate

Aggregate

interface Aggregate

Functions

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