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)