DefaultPipelineFlushStrategy

constructor(@Value(value = "${airbyte.destination.core.record-batch-size-override:null}") microBatchOverride: Long? = null, config: DestinationConfiguration)