org.apache.paimon.utils

Class FutureUtils

java.lang.Object

org.apache.paimon.utils.FutureUtils

public class FutureUtils
extends Object

A collection of utilities that expand the usage of CompletableFuture.

Constructor Summary

Constructors

Constructor and Description
FutureUtils()

Method Summary

Modifier and Type	Method and Description
static <T> CompletableFuture<T>	completedExceptionally(Throwable cause) Returns an exceptionally completed CompletableFuture.
static <T> void	doForward(T value, Throwable throwable, CompletableFuture<T> target) Completes the given future with either the given value or throwable, depending on which parameter is not null.
static <T> void	forward(CompletableFuture<T> source, CompletableFuture<T> target) Forwards the value from the source future to the target future.

Methods inherited from class java.lang.Object

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

Constructor Detail

FutureUtils

public FutureUtils()

Method Detail

completedExceptionally

public static <T> CompletableFuture<T> completedExceptionally(Throwable cause)

Returns an exceptionally completed CompletableFuture.

Type Parameters:

T - type of the future

Parameters:

cause - to complete the future with

Returns:

An exceptionally completed CompletableFuture

forward

public static <T> void forward(CompletableFuture<T> source,
                               CompletableFuture<T> target)

Forwards the value from the source future to the target future.

Type Parameters:

T - type of the value

Parameters:

source - future to forward the value from

target - future to forward the value to

doForward

public static <T> void doForward(@Nullable
                                 T value,
                                 @Nullable
                                 Throwable throwable,
                                 CompletableFuture<T> target)

Completes the given future with either the given value or throwable, depending on which parameter is not null.

Type Parameters:

T - completed future

Parameters:

value - value with which the future should be completed

throwable - throwable with which the future should be completed exceptionally

target - future to complete