Package | Description |
---|---|
org.apache.flink.runtime.messages.accumulators |
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.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.