SocketInputFlow

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

Constructors

Link copied to clipboard
constructor(catalog: DestinationCatalog, socket: ClientSocket, inputFormatReader: DataChannelReader, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter, memoryManager: ReservationManager, logPerNRecords: Long)

Functions

Link copied to clipboard
open suspend override fun collect(collector: FlowCollector<PipelineInputEvent>)