Class InternalAvroStoreClient<K,​V>

    • Constructor Detail

      • InternalAvroStoreClient

        public InternalAvroStoreClient()
    • Method Detail

      • getRaw

        public java.util.concurrent.CompletableFuture<byte[]> getRaw​(java.lang.String requestPath)
      • get

        public java.util.concurrent.CompletableFuture<V> get​(K key)
                                                      throws VeniceClientException
        Description copied from interface: AvroGenericStoreClient
        Lookup the value by given key, and get(key).get() will return null if it doesn't exist. For now, if any backend error/exception happens, get(Object key).get() will throw ExecutionException, which is a wrapper of the real exception.
        Specified by:
        get in interface AvroGenericStoreClient<K,​V>
      • getRaw

        public abstract java.util.concurrent.CompletableFuture<byte[]> getRaw​(java.lang.String requestPath,
                                                                              java.util.Optional<ClientStats> stats,
                                                                              long preRequestTimeInNS)
      • getDeserializationExecutor

        public java.util.concurrent.Executor getDeserializationExecutor()