SocketInputFlow
class SocketInputFlow(catalog: DestinationCatalog, socket: ClientSocket, inputFormatReader: DataChannelReader, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter, memoryManager: ReservationManager, logPerNRecords: Long) : Flow<PipelineInputEvent> (source)
Constructors
Link copied to clipboard
constructor(catalog: DestinationCatalog, socket: ClientSocket, inputFormatReader: DataChannelReader, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter, memoryManager: ReservationManager, logPerNRecords: Long)