OUT- Output type
@PublicEvolving public interface ResultFuture<OUT>
ResultFuturecollects data / error in user codes while processing async i/o.
|Modifier and Type||Method and Description|
Completes the result future with a collection of result objects.
Completes the result future exceptionally with an exception.
void complete(Collection<OUT> result)
Note that it should be called for exactly one time in the user code. Calling this function for multiple times will cause data lose.
Put all results in a
Collection and then emit output.
result- A list of results.
void completeExceptionally(Throwable error)
error- A Throwable object.
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.