public final class NumericThreshold<E> implements BatchingThreshold<E>A threshold which accumulates a count based on the provided ElementCounter.
Implements
BatchingThreshold<E>Type Parameter |
|
|---|---|
| Name | Description |
E |
|
Constructors
NumericThreshold(long threshold, ElementCounter<E> extractor)
public NumericThreshold(long threshold, ElementCounter<E> extractor)Constructs a NumericThreshold.
| Parameters | |
|---|---|
| Name | Description |
threshold |
longThe value that allows an event to happen. |
extractor |
ElementCounter<E>Object that extracts a numeric value from the value object. |
Methods
accumulate(E e)
public void accumulate(E e)Presents the element to the threshold for the attribute of interest to be accumulated.
Any calls into this function from ThresholdBatcher will be under a lock.
| Parameter | |
|---|---|
| Name | Description |
e |
E |
copyWithZeroedValue()
public BatchingThreshold<E> copyWithZeroedValue()Make a copy of this threshold but with the accumulated value zeroed.
Any calls into this function from ThresholdBatcher will be under a lock.
| Returns | |
|---|---|
| Type | Description |
BatchingThreshold<E> |
|
isThresholdReached()
public boolean isThresholdReached()Any calls into this function from ThresholdBatcher will be under a lock.
| Returns | |
|---|---|
| Type | Description |
boolean |
|