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

Package-level declarations

Types

Link copied to clipboard
class ClientSocket(val socketPath: String, bufferSizeBytes: Int, connectWaitDelayMs: Long = 1000, connectTimeoutMs: Long = 15 * 60 * 1000L)
Link copied to clipboard
class ProtobufDataChannelReader(factory: DestinationMessageFactory, bufferSize: Int = 16 * 1024)

Performs non-cooperative blocking IO.