org.openimaj.demos.sandbox.ml.linear.learner.stream

Class StockPriceAggregator

java.lang.Object

org.openimaj.util.stream.window.SequentialStreamAggregator<Context>

org.openimaj.demos.sandbox.ml.linear.learner.stream.StockPriceAggregator

All Implemented Interfaces:

Function<Stream<Context>,Stream<Context>>

public final class StockPriceAggregator
extends SequentialStreamAggregator<Context>

Given a paired stream of user-word-counts and ticker-price, implement a SequentialStreamAggregator with a comparator which tests stock prices. Identical stock prices (i.e. the same for each ticker) are combined

Author:

Sina Samangooei (ss@ecs.soton.ac.uk)

Constructor Summary

Constructors

Constructor and Description
StockPriceAggregator(double thresh)

Method Summary

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

Methods inherited from class org.openimaj.util.stream.window.SequentialStreamAggregator

apply

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

StockPriceAggregator

public StockPriceAggregator(double thresh)

Method Detail

combine

public Context combine(List<Context> window)

Description copied from class: SequentialStreamAggregator

Called when a window of identical items needs to be combined

Specified by:

combine in class SequentialStreamAggregator<Context>

Returns:

the combination of the current and next values

main

public static void main(String[] args)

tests

Parameters:

args -