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.client.program
org.apache.flink.client.program.rest
org.apache.flink.runtime.accumulators
org.apache.flink.runtime.client
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobmaster
org.apache.flink.runtime.rest.messages
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 and 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 and 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 and 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 void	AccumulatorHelper.mergeInto(Map<String,OptionalFailure<Accumulator<?,?>>> target, Map<String,Accumulator<?,?>> toMerge) Merge two collections of accumulators.

Uses of OptionalFailure in org.apache.flink.client.program

Methods in org.apache.flink.client.program that return types with arguments of type OptionalFailure

Modifier and Type	Method and Description
Map<String,OptionalFailure<Object>>	ClusterClient.getAccumulators(JobID jobID) Requests and returns the accumulators for the given job identifier.
Map<String,OptionalFailure<Object>>	MiniClusterClient.getAccumulators(JobID jobID)
Map<String,OptionalFailure<Object>>	ClusterClient.getAccumulators(JobID jobID, ClassLoader loader) Requests and returns the accumulators for the given job identifier.
Map<String,OptionalFailure<Object>>	MiniClusterClient.getAccumulators(JobID jobID, ClassLoader loader)

Uses of OptionalFailure in org.apache.flink.client.program.rest

Methods in org.apache.flink.client.program.rest that return types with arguments of type OptionalFailure

Modifier and Type	Method and Description
Map<String,OptionalFailure<Object>>	RestClusterClient.getAccumulators(JobID jobID, ClassLoader loader)

Uses of OptionalFailure in org.apache.flink.runtime.accumulators

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

Modifier and Type	Method and Description
static StringifiedAccumulatorResult[]	StringifiedAccumulatorResult.stringifyAccumulatorResults(Map<String,OptionalFailure<Accumulator<?,?>>> accs) Flatten a map of accumulator names to Accumulator instances into an array of StringifiedAccumulatorResult values.

Uses of OptionalFailure in org.apache.flink.runtime.client

Methods in org.apache.flink.runtime.client that return types with arguments of type OptionalFailure

Modifier and Type	Method and Description
Map<String,SerializedValue<OptionalFailure<Object>>>	SerializedJobExecutionResult.getSerializedAccumulatorResults()

Constructor parameters in org.apache.flink.runtime.client with type arguments of type OptionalFailure

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

Uses of OptionalFailure in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph that return types with arguments of type OptionalFailure

Modifier and Type	Method and Description
Map<String,OptionalFailure<Accumulator<?,?>>>	ExecutionGraph.aggregateUserAccumulators() Merges all accumulator results from the tasks previously executed in the Executions.
Map<String,SerializedValue<OptionalFailure<Object>>>	AccessExecutionGraph.getAccumulatorsSerialized() Returns a map containing the serialized values of user-defined accumulators.
Map<String,SerializedValue<OptionalFailure<Object>>>	ExecutionGraph.getAccumulatorsSerialized() Gets a serialized accumulator map.
Map<String,SerializedValue<OptionalFailure<Object>>>	ArchivedExecutionGraph.getAccumulatorsSerialized()

Constructor parameters in org.apache.flink.runtime.executiongraph with type arguments of type OptionalFailure

Constructor and Description

ArchivedExecutionGraph(JobID jobID, String jobName, Map<JobVertexID,ArchivedExecutionJobVertex> tasks, List<ArchivedExecutionJobVertex> verticesInCreationOrder, long[] stateTimestamps, JobStatus state, ErrorInfo failureCause, String jsonPlan, StringifiedAccumulatorResult[] archivedUserAccumulators, Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators, ArchivedExecutionConfig executionConfig, boolean isStoppable, CheckpointCoordinatorConfiguration jobCheckpointingConfiguration, CheckpointStatsSnapshot checkpointStatsSnapshot)

Uses of OptionalFailure in org.apache.flink.runtime.jobmaster

Methods in org.apache.flink.runtime.jobmaster that return types with arguments of type OptionalFailure

Modifier and Type	Method and Description
Map<String,SerializedValue<OptionalFailure<Object>>>	JobResult.getAccumulatorResults()

Method parameters in org.apache.flink.runtime.jobmaster with type arguments of type OptionalFailure

Modifier and Type	Method and Description
JobResult.Builder	JobResult.Builder.accumulatorResults(Map<String,SerializedValue<OptionalFailure<Object>>> accumulatorResults)

Uses of OptionalFailure in org.apache.flink.runtime.rest.messages

Methods in org.apache.flink.runtime.rest.messages that return types with arguments of type OptionalFailure

Modifier and Type	Method and Description
Map<String,SerializedValue<OptionalFailure<Object>>>	JobAccumulatorsInfo.getSerializedUserAccumulators()

Constructor parameters in org.apache.flink.runtime.rest.messages with type arguments of type OptionalFailure

Constructor and Description
JobAccumulatorsInfo(List<JobAccumulatorsInfo.JobAccumulator> jobAccumulators, List<JobAccumulatorsInfo.UserTaskAccumulator> userAccumulators, Map<String,SerializedValue<OptionalFailure<Object>>> serializedUserAccumulators)

Uses of OptionalFailure in org.apache.flink.util

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

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