Package | Description |
---|---|
org.apache.flink.contrib.operatorstatistics.heavyhitters |
Modifier and Type | Class and Description |
---|---|
class |
CountMinHeavyHitter |
class |
LossyCounting
Implements Lossy Counting algorithm (Manku, G.S., Motwani, R.: Approximate frequency counts over data streams, 2002)
The algorithm tracks heavy hitters in a count based fashion.
|
Modifier and Type | Method and Description |
---|---|
void |
CountMinHeavyHitter.merge(HeavyHitter toMerge) |
void |
LossyCounting.merge(HeavyHitter toMerge) |
void |
HeavyHitter.merge(HeavyHitter toMerge) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.