bulk-cdk-core-load/io.airbyte.cdk.load.state/DefaultDestinationStateManager

DefaultDestinationStateManager

@Singleton
@Secondary
class DefaultDestinationStateManager<T : DestinationState>(persister: DestinationStatePersister<T>) : DestinationStateManager<T>

Constructors

Link copied to clipboard
constructor(persister: DestinationStatePersister<T>)

Functions

Link copied to clipboard
open suspend override fun getState(stream: DestinationStream): T
Link copied to clipboard
open suspend override fun persistState(stream: DestinationStream)