Class AbstractRecordStreamDecoder<ENVELOPE,​K,​V>

  • Type Parameters:
    K -
    V -
    All Implemented Interfaces:
    RecordStreamDecoder, TransportClientStreamingCallback
    Direct Known Subclasses:
    ComputeRecordStreamDecoder, MultiGetRecordStreamDecoder

    public abstract class AbstractRecordStreamDecoder<ENVELOPE,​K,​V>
    extends java.lang.Object
    implements RecordStreamDecoder
    Streaming callback for batch-get/compute. Since data chunk returned by D2TransportClient doesn't respect chunk-size associated with each chunk sent by Venice Router, here is leveraging ReadEnvelopeChunkedDeserializer to deserialize data chunks even with the data chunk contains partial record in a non-blocking way. The envelope deserialization will happen in TransportClient thread pool (R2 thread pool for example if using D2TransportClient, and both the record deserialization and application's callback will be executed in Venice thread pool: deserializationExecutor,