Package com.linkedin.venice.client.store.streaming

Class VeniceResponseCompletableFuture<T>

java.lang.Object

java.util.concurrent.CompletableFuture<T>

com.linkedin.venice.client.store.streaming.VeniceResponseCompletableFuture<T>

Type Parameters:

T -

All Implemented Interfaces:

CompletionStage<T>, Future<T>

public class VeniceResponseCompletableFuture<T>
extends CompletableFuture<T>

CompletableFuture implementation to handle partial response.

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.CompletableFuture

CompletableFuture.AsynchronousCompletionTask

Constructor Summary

Constructors

Constructor	Description
VeniceResponseCompletableFuture(Supplier<VeniceResponseMap> supplier, int totalKeyCnt, Optional<ClientStats> stats)

Method Summary

Modifier and Type	Method	Description
T	get(long timeout, TimeUnit unit)

Methods inherited from class java.util.concurrent.CompletableFuture

acceptEither, acceptEitherAsync, acceptEitherAsync, allOf, anyOf, applyToEither, applyToEitherAsync, applyToEitherAsync, cancel, complete, completeAsync, completeAsync, completedFuture, completedStage, completeExceptionally, completeOnTimeout, copy, defaultExecutor, delayedExecutor, delayedExecutor, exceptionally, exceptionallyAsync, exceptionallyAsync, exceptionallyCompose, exceptionallyComposeAsync, exceptionallyComposeAsync, failedFuture, failedStage, get, getNow, getNumberOfDependents, handle, handleAsync, handleAsync, isCancelled, isCompletedExceptionally, isDone, join, minimalCompletionStage, newIncompleteFuture, obtrudeException, obtrudeValue, orTimeout, runAfterBoth, runAfterBothAsync, runAfterBothAsync, runAfterEither, runAfterEitherAsync, runAfterEitherAsync, runAsync, runAsync, supplyAsync, supplyAsync, thenAccept, thenAcceptAsync, thenAcceptAsync, thenAcceptBoth, thenAcceptBothAsync, thenAcceptBothAsync, thenApply, thenApplyAsync, thenApplyAsync, thenCombine, thenCombineAsync, thenCombineAsync, thenCompose, thenComposeAsync, thenComposeAsync, thenRun, thenRunAsync, thenRunAsync, toCompletableFuture, toString, whenComplete, whenCompleteAsync, whenCompleteAsync

Methods inherited from class java.lang.Object

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

Constructor Details

VeniceResponseCompletableFuture

public VeniceResponseCompletableFuture(Supplier<VeniceResponseMap> supplier,
 int totalKeyCnt,
 Optional<ClientStats> stats)

Method Details

get

public T get(long timeout,
 TimeUnit unit)
      throws InterruptedException,
ExecutionException

Specified by:

get in interface Future<T>

Overrides:

get in class CompletableFuture<T>

Throws:

InterruptedException

ExecutionException