Uses of Class
org.apache.flink.util.OptionalFailure

Packages that use OptionalFailure

Package	Description
org.apache.flink.api.common
org.apache.flink.api.common.accumulators
org.apache.flink.util

Uses of OptionalFailure in org.apache.flink.api.common

Constructor parameters in org.apache.flink.api.common with type arguments of type OptionalFailure

Constructor	Description
JobExecutionResult(JobID jobID, long netRuntime, Map<String,OptionalFailure<Object>> accumulators)	Creates a new JobExecutionResult.

Uses of OptionalFailure in org.apache.flink.api.common.accumulators

Methods in org.apache.flink.api.common.accumulators that return types with arguments of type OptionalFailure

Modifier and Type	Method	Description
static Map<String,OptionalFailure<Object>>	AccumulatorHelper.deserializeAccumulators(Map<String,SerializedValue<OptionalFailure<Object>>> serializedAccumulators, ClassLoader loader)	Takes the serialized accumulator results and tries to deserialize them using the provided class loader.
static Map<String,OptionalFailure<Object>>	AccumulatorHelper.toResultMap(Map<String,Accumulator<?,?>> accumulators)	Transform the Map with accumulators into a Map containing only the results.

Method parameters in org.apache.flink.api.common.accumulators with type arguments of type OptionalFailure

Modifier and Type	Method	Description
static Map<String,OptionalFailure<Object>>	AccumulatorHelper.deserializeAccumulators(Map<String,SerializedValue<OptionalFailure<Object>>> serializedAccumulators, ClassLoader loader)	Takes the serialized accumulator results and tries to deserialize them using the provided class loader.
static Map<String,Object>	AccumulatorHelper.deserializeAndUnwrapAccumulators(Map<String,SerializedValue<OptionalFailure<Object>>> serializedAccumulators, ClassLoader loader)	Takes the serialized accumulator results and tries to deserialize them using the provided class loader, and then try to unwrap the value unchecked.
static void	AccumulatorHelper.mergeInto(Map<String,OptionalFailure<Accumulator<?,?>>> target, Map<String,Accumulator<?,?>> toMerge)	Merge two collections of accumulators.

Uses of OptionalFailure in org.apache.flink.util

Methods in org.apache.flink.util that return OptionalFailure

Modifier and Type	Method	Description
static <T> OptionalFailure<T>	OptionalFailure.createFrom(org.apache.flink.util.function.CheckedSupplier<T> valueSupplier)
static <T> OptionalFailure<T>	OptionalFailure.of(T value)
static <T> OptionalFailure<T>	OptionalFailure.ofFailure(Throwable failureCause)