Package | Description |
---|---|
org.apache.flink.runtime.messages.accumulators |
Modifier and Type | Interface and Description |
---|---|
interface |
AccumulatorResultsResponse
Base trait of responses to
RequestAccumulatorResults |
Modifier and Type | Class and Description |
---|---|
class |
AccumulatorResultsErroneous
Denotes that the accumulator results for
jobID could be obtained from
the JobManager because of an exception. |
class |
AccumulatorResultsFound
Contains the retrieved accumulator results from the job manager.
|
class |
AccumulatorResultsNotFound
Denotes that no accumulator results for
jobID could be found at the job manager. |
class |
AccumulatorResultStringsFound
Contains the retrieved accumulator result strings from the job manager.
|
class |
RequestAccumulatorResults
Requests the accumulator results of the job identified by
jobID from the job manager. |
class |
RequestAccumulatorResultsStringified
Requests the accumulator results of the job as strings.
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.