public final class StockPriceAggregator extends SequentialStreamAggregator<Context>
SequentialStreamAggregator
with a comparator which tests stock
prices. Identical stock prices (i.e. the same for each ticker) are combinedConstructor and Description |
---|
StockPriceAggregator(double thresh) |
Modifier and Type | Method and Description |
---|---|
Context |
combine(List<Context> window)
Called when a window of identical items needs to be combined
|
static void |
main(String[] args)
tests
|
apply
public StockPriceAggregator(double thresh)
public Context combine(List<Context> window)
SequentialStreamAggregator
combine
in class SequentialStreamAggregator<Context>