SocketInputFlow
constructor(catalog: DestinationCatalog, socket: ClientSocket, inputFormatReader: DataChannelReader, pipelineEventBookkeepingRouter: PipelineEventBookkeepingRouter, memoryManager: ReservationManager, logPerNRecords: Long)