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

flush

abstract suspend fun flush()