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 java.lang.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 ClientConfig	clientConfig
protected java.util.concurrent.Executor	deserializationExecutor

Method Summary

Modifier and Type	Method	Description
abstract void	deserialize(java.util.concurrent.CompletableFuture<java.util.Map<K,V>> valueFuture, java.lang.Iterable<E> records, java.util.List<K> keyList, java.util.function.BiConsumer<java.util.Map<K,V>,E> envelopeProcessor, Reporter responseDeserializationComplete, java.util.Optional<ClientStats> stats, long preResponseEnvelopeDeserialization)

Methods inherited from class java.lang.Object

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

Field Detail

deserializationExecutor

protected final java.util.concurrent.Executor deserializationExecutor

clientConfig

protected final ClientConfig clientConfig

Method Detail

deserialize

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