Package | Description |
---|---|
org.apache.flink.contrib.operatorstatistics |
Class and Description |
---|
OperatorStatistics
Data structure that encapsulates statistical information of data that has only been processed by one pass
This statistical information is meant to help determine the distribution of the data that has been processed
in an operator so that we can determine if it is necessary to repartition the data
The statistics to be gathered are configurable and represented by a
OperatorStatisticsConfig object. |
OperatorStatisticsConfig
Configures the behavior of an
OperatorStatistics instance. |
OperatorStatisticsConfig.CountDistinctAlgorithm |
OperatorStatisticsConfig.HeavyHitterAlgorithm |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.