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

Class 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.

    • Constructor Summary

      Constructors 
      Constructor Description
      BlackHoleDeserializer​(java.util.concurrent.Executor deserializationExecutor, ClientConfig clientConfig)  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      void deserialize​(java.util.concurrent.CompletableFuture<java.util.Map<K,​V>> valueFuture, java.lang.Iterable<E> envelopes, 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

    • Constructor Detail

      • BlackHoleDeserializer

        public BlackHoleDeserializer​(java.util.concurrent.Executor deserializationExecutor,
                             ClientConfig clientConfig)

    • Method Detail

      • deserialize

        public void deserialize​(java.util.concurrent.CompletableFuture<java.util.Map<K,​V>> valueFuture,
                        java.lang.Iterable<E> envelopes,
                        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)
        Specified by:
        deserialize in class BatchDeserializer<E,​K,​V>