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 | long The 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 |