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

Class BlackHoleDeserializer<E,K,V>

java.lang.Object

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

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

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

This BatchDeserializer does nothing, and always returns an empty list. The intent is to use this serializer in order to stress the Venice backend services with more requests, while doing as little work as possible in the client. This can also be used to test the transport-only portion of the client, without any deserialization costs.

Field Summary

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

clientConfig, deserializationExecutor

Constructor Summary

Constructors

Constructor	Description
BlackHoleDeserializer(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

BlackHoleDeserializer

public BlackHoleDeserializer(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>