Airbyte Kotlin Bulk CDK

0.1.92

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

Package-level declarations

Types

class ClientSocket(val socketPath: String, bufferSizeBytes: Int, connectWaitDelayMs: Long = 1000, connectTimeoutMs: Long = 15 * 60 * 1000L)

DataChannelReader

interface DataChannelReader

DefaultTimeProvider

@Singleton

@Secondary

class DefaultTimeProvider : TimeProvider

data object GZIPProcessor : StreamProcessor<BufferedOutputStream>

JSONLDataChannelReader

class JSONLDataChannelReader(destinationMessageFactory: DestinationMessageFactory) : DataChannelReader

data object NoopProcessor : StreamProcessor<ByteArrayOutputStream>

ProtobufDataChannelReader

class ProtobufDataChannelReader(factory: DestinationMessageFactory, bufferSize: Int = 16 * 1024) : DataChannelReader

Performs non-cooperative blocking IO.

SocketInputFlow

class SocketInputFlow(catalog: DestinationCatalog, socket: ClientSocket, inputFormatReader: DataChannelReader, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter, memoryManager: ReservationManager, logPerNRecords: Long) : Flow<PipelineInputEvent>

StreamProcessor

interface StreamProcessor<T : OutputStream>

interface TimeProvider