Package | Description |
---|---|
org.apache.flink.runtime.accumulators | |
org.apache.flink.runtime.executiongraph |
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.
|
Constructor and Description |
---|
ArchivedExecution(StringifiedAccumulatorResult[] userAccumulators,
IOMetrics ioMetrics,
ExecutionAttemptID attemptId,
int attemptNumber,
ExecutionState state,
String failureCause,
TaskManagerLocation assignedResourceLocation,
AllocationID assignedAllocationID,
int parallelSubtaskIndex,
long[] stateTimestamps) |
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) |
ArchivedExecutionJobVertex(ArchivedExecutionVertex[] taskVertices,
JobVertexID id,
String name,
int parallelism,
int maxParallelism,
StringifiedAccumulatorResult[] archivedUserAccumulators) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.