Package com.linkedin.venice.router.streaming
package com.linkedin.venice.router.streaming
-
ClassDescriptionThis class was copied from
ChunkedWriteHandler, and the only change we made here is to usingConcurrentLinkedQueueforNettyChunkedWriteHandler.queuesinceNettyChunkedWriteHandler.resumeTransfer()orNettyChunkedWriteHandler.discard(Throwable)could happen in any sequence with any parallelism because of scatter/gather logic in Venice Router.Full response to indicate that all the sub responses are with good status:HttpResponseStatus.OKfor streaming request.This is the class to talk toVeniceChunkedWriteHandlerto send back partial response.This class is the wrapper ofChunkedWriteHandler, and essentially it will introduce the following logic: 1.