bulk-cdk-toolkit-load-object-storage/io.airbyte.cdk.load.state.object_storage

Package-level declarations

Types

class ObjectStorageDestinationState(stream: DestinationStream, client: ObjectStorageClient<*>, pathFactory: PathFactory, destinationConfig: DestinationConfiguration) : DestinationState

ObjectStorageFallbackPersister

@Singleton

class ObjectStorageFallbackPersister(client: ObjectStorageClient<*>, pathFactory: PathFactory, destinationConfig: DestinationConfiguration) : DestinationStatePersister<ObjectStorageDestinationState>

Note: there's no persisting yet. This will require either a client-provided path to store data or a guaranteed sortable set of file names so that we can send the high watermark to the platform.