Airbyte Kotlin Bulk CDK

0.1.92

bulk-cdk-toolkit-load-db/io.airbyte.cdk.load.write.db/InsertLoaderRequestBuilder

InsertLoaderRequestBuilder

interface InsertLoaderRequestBuilder<Q : InsertLoaderRequest> : AutoCloseable

Types

InsertAcceptResult

sealed interface InsertAcceptResult<Q>

class NoOutput<Q> : InsertLoaderRequestBuilder.InsertAcceptResult<Q>

data class Request<Q>(val request: Q) : InsertLoaderRequestBuilder.InsertAcceptResult<Q>

Functions

abstract fun accept(record: DestinationRecordRaw, maxRequestSizeBytes: Long): InsertLoaderRequestBuilder.InsertAcceptResult<Q>

abstract fun close()

abstract fun finish(): InsertLoaderRequestBuilder.Request<Q>