Interface | Description |
---|---|
AccumulatorRegistry.Reporter |
Interface for Flink's internal accumulators.
|
Class | Description |
---|---|
AccumulatorRegistry |
Main accumulator registry which encapsulates internal and user-defined accumulators.
|
AccumulatorSnapshot |
This class encapsulates a map of accumulators for a single task.
|
StringifiedAccumulatorResult |
Container class that transports the result of an accumulator as set of strings.
|
Enum | Description |
---|---|
AccumulatorRegistry.Metric |
Flink metrics supported
|
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.