Package org.apache.flink.util.function

Class FunctionUtils

java.lang.Object

org.apache.flink.util.function.FunctionUtils

public class FunctionUtils
extends Object

Utility class for Flink's functions.

Method Summary

Modifier and Type	Method	Description
static <T> Callable<T>	asCallable(RunnableWithException command, T result)	Converts RunnableWithException into a Callable that will return the result.
static <T> java.util.function.Consumer<T>	ignoreFn()	Consumer which ignores the input.
static <T> java.util.function.Function<T,Void>	nullFn()	Function which returns null (type: Void).
static <A> java.util.function.Consumer<A>	uncheckedConsumer(ThrowingConsumer<A,?> throwingConsumer)	Converts a ThrowingConsumer into a Consumer which throws checked exceptions as unchecked.
static <A,B> java.util.function.Function<A,B>	uncheckedFunction(FunctionWithException<A,B,?> functionWithException)	Convert at FunctionWithException into a Function.
static <T> java.util.function.Supplier<T>	uncheckedSupplier(SupplierWithException<T,?> supplierWithException)	Converts a SupplierWithException into a Supplier which throws all checked exceptions as unchecked.

Methods inherited from class java.lang.Object

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

Method Detail

nullFn

public static <T> java.util.function.Function<T,Void> nullFn()

Function which returns null (type: Void).

Type Parameters:

T - input type

Returns:

Function which returns null.

ignoreFn

public static <T> java.util.function.Consumer<T> ignoreFn()

Consumer which ignores the input.

Type Parameters:

T - type of the input

Returns:

Ignoring Consumer

uncheckedFunction

public static <A,B> java.util.function.Function<A,B> uncheckedFunction(FunctionWithException<A,B,?> functionWithException)

Convert at FunctionWithException into a Function.

Type Parameters:

A - input type

B - output type

Parameters:

functionWithException - function with exception to convert into a function

Returns:

Function which throws all checked exception as an unchecked exception.

uncheckedConsumer

public static <A> java.util.function.Consumer<A> uncheckedConsumer(ThrowingConsumer<A,?> throwingConsumer)

Converts a ThrowingConsumer into a Consumer which throws checked exceptions as unchecked.

Type Parameters:

A - input type

Parameters:

throwingConsumer - to convert into a Consumer

Returns:

Consumer which throws all checked exceptions as unchecked

uncheckedSupplier

public static <T> java.util.function.Supplier<T> uncheckedSupplier(SupplierWithException<T,?> supplierWithException)

Converts a SupplierWithException into a Supplier which throws all checked exceptions as unchecked.

Parameters:

supplierWithException - to convert into a Supplier

Returns:

Supplier which throws all checked exceptions as unchecked.

asCallable

public static <T> Callable<T> asCallable(RunnableWithException command,
                                         T result)

Converts RunnableWithException into a Callable that will return the result.