BaseDirectLoadInitialStatusGatherer
abstract class BaseDirectLoadInitialStatusGatherer(airbyteClient: AirbyteClient, tempTableNameGenerator: TempTableNameGenerator) : DatabaseInitialStatusGatherer<DirectLoadInitialStatus>
Functions
Link copied to clipboard
open suspend override fun gatherInitialStatus(streams: TableCatalog): Map<DestinationStream, DirectLoadInitialStatus>