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

Class BatchDeserializer<E,K,V>

java.lang.Object

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

Direct Known Subclasses:

BlackHoleDeserializer, BlockingDeserializer

public abstract class BatchDeserializer<E,K,V>
extends Object

This API controls the behavior of the user payload deserialization phase of the batch get response handling.

Field Summary

Fields

Modifier and Type	Field	Description
protected final ClientConfig	clientConfig
protected final Executor	deserializationExecutor

Method Summary

Modifier and Type	Method	Description
abstract void	deserialize(CompletableFuture<Map<K,V>> valueFuture, Iterable<E> records, 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

Field Details

deserializationExecutor

protected final Executor deserializationExecutor

clientConfig

protected final ClientConfig clientConfig

Method Details

deserialize

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