Package-level declarations

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

DirectLoader is for the use case where records are loaded directly into the destination or staged in chunks with a 3rd party library (eg, Iceberg)

Override to provide a custom input stream.

Implementor interface. A stream event handler.

Thrown when the destination completes successfully, but some streams were indicated as incomplete by upstream. Without throwing an exception the sync will not be marked as succeed by the platform.

Can be used by the dev connector to pass state between different parts of the connector. To use it is sufficient to inject a StreamStateStore of any type into any component. The expected use is for making state generated during initialization generally available to the Loaders.

Write operation. Executed by the core framework when the operation is "write". Launches the core services and awaits completion.

Allows the write operation to be overridden completely. This is not intended for developing production connectors, but for making non-release test tags. (For example, performance experiments to test in the cloud.)