Package com.linkedin.venice.client.store.deserialization

Class BlockingDeserializer<E,K,V>

java.lang.Object

com.linkedin.venice.client.store.deserialization.BatchDeserializer<E,K,V>

com.linkedin.venice.client.store.deserialization.BlockingDeserializer<E,K,V>

public class BlockingDeserializer<E,K,V>
extends BatchDeserializer<E,K,V>

This BatchDeserializer does not do anything asynchronously. It simply deserializes all records sequentially on the same thread that called it.

Field Summary

Fields inherited from class com.linkedin.venice.client.store.deserialization.BatchDeserializer

clientConfig, deserializationExecutor

Constructor Summary

Constructors

Constructor	Description
BlockingDeserializer(Executor deserializationExecutor, ClientConfig clientConfig)

Method Summary

Modifier and Type	Method	Description
void	deserialize(CompletableFuture<Map<K,V>> valueFuture, Iterable<E> envelopes, List<K> keyList, BiConsumer<Map<K,V>,E> envelopeProcessor, Reporter responseDeserializationComplete, Optional<ClientStats> stats, long preResponseEnvelopeDeserialization)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

BlockingDeserializer

public BlockingDeserializer(Executor deserializationExecutor,
 ClientConfig clientConfig)

Method Details

deserialize

public void deserialize(CompletableFuture<Map<K,V>> valueFuture,
 Iterable<E> envelopes,
 List<K> keyList,
 BiConsumer<Map<K,V>,E> envelopeProcessor,
 Reporter responseDeserializationComplete,
 Optional<ClientStats> stats,
 long preResponseEnvelopeDeserialization)

Specified by:

deserialize in class BatchDeserializer<E,K,V>