bulk-cdk-core-load/io.airbyte.cdk.load.write

Package-level declarations

Types

Link copied to clipboard
interface DestinationWriter

Implementor interface. Every Destination must extend this and at least provide an implementation of createStreamLoader.

Link copied to clipboard
interface StreamLoader

Implementor interface. A stream event handler.

Link copied to clipboard
@Singleton
class StreamStateStore<S>

TODO: Deprecate

Link copied to clipboard
@Singleton
@Requires(property = "airbyte.connector.operation", value = "write")
class WriteOperation(destinationLifecycle: DestinationLifecycle) : Operation