Package | Description |
---|---|
org.apache.flink.runtime.accumulators | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.messages.accumulators |
Modifier and Type | Method and Description |
---|---|
static StringifiedAccumulatorResult[] |
StringifiedAccumulatorResult.stringifyAccumulatorResults(Map<String,Accumulator<?,?>> accs)
Flatten a map of accumulator names to Accumulator instances into an array of StringifiedAccumulatorResult values
|
Modifier and Type | Method and Description |
---|---|
StringifiedAccumulatorResult[] |
ExecutionGraph.getAccumulatorResultsStringified()
Returns the a stringified version of the user-defined accumulators.
|
StringifiedAccumulatorResult[] |
ExecutionJobVertex.getAggregatedUserAccumulatorsStringified() |
StringifiedAccumulatorResult[] |
Execution.getUserAccumulatorsStringified() |
Modifier and Type | Method and Description |
---|---|
StringifiedAccumulatorResult[] |
AccumulatorResultStringsFound.result() |
Constructor and Description |
---|
AccumulatorResultStringsFound(JobID jobID,
StringifiedAccumulatorResult[] result) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.