T
- type of data in the stream to be summarizedpublic class ConcurrentStreamSummary<T> extends Object implements ITopK<T>
StreamSummary
Constructor and Description |
---|
ConcurrentStreamSummary(int capacity) |
Modifier and Type | Method and Description |
---|---|
boolean |
offer(T element)
offer a single element to the top.
|
boolean |
offer(T element,
int incrementCount)
offer a single element to the top and increment the count
for that element by incrementCount.
|
List<T> |
peek(int k) |
List<ScoredItem<T>> |
peekWithScores(int k) |
String |
toString() |
public boolean offer(T element)
ITopK
public boolean offer(T element, int incrementCount)
ITopK
public List<ScoredItem<T>> peekWithScores(int k)
Copyright © 2019. All rights reserved.