Package | Description |
---|---|
org.apache.flink.runtime.messages.accumulators |
Class and Description |
---|
AccumulatorMessage
Base trait of all accumulator messages
|
AccumulatorResultsErroneous$ |
AccumulatorResultsFound$ |
AccumulatorResultsNotFound$ |
AccumulatorResultsResponse
Base trait of responses to
RequestAccumulatorResults |
AccumulatorResultStringsFound$ |
RequestAccumulatorResults$ |
RequestAccumulatorResultsStringified$ |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.