Package com.hybris.ymkt.recommendation.services

Class ImpressionAggregatorServiceTest.ImpressionAggregatorService

java.lang.Object

com.hybris.ymkt.recommendation.services.ImpressionAggregatorServiceTest.ImpressionAggregatorService

Enclosing class:

ImpressionAggregatorServiceTest

public static class ImpressionAggregatorServiceTest.ImpressionAggregatorService
extends Object

To be used to aggregate impressions from UI before persisting to DB.
Expected to be consumed in multi-threaded environment.

Field Summary

Fields

Modifier and Type	Field	Description
protected final Map<String,Map<Long,ImpressionAggregatorServiceTest.ImpressionCounter>>	counters
protected int	window
protected int	window_2

Constructor Summary

Constructors

Constructor	Description
ImpressionAggregatorService()

Method Summary

Modifier and Type	Method	Description
void	addImpression(String scenarioId, int itemCount)
void	addImpression(String scenarioId, int impressionCount, int itemCount, long time)
protected long	key(long time)
List<ImpressionAggregatorServiceTest.Impression>	remove()
protected List<ImpressionAggregatorServiceTest.Impression>	removeInternal(long time)

Methods inherited from class java.lang.Object

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

Field Details

window

protected int window

window_2

protected int window_2

counters

protected final Map<String,Map<Long,ImpressionAggregatorServiceTest.ImpressionCounter>> counters

Constructor Details

ImpressionAggregatorService

public ImpressionAggregatorService()

Method Details

addImpression

public void addImpression(String scenarioId,
 int itemCount)

addImpression

public void addImpression(String scenarioId,
 int impressionCount,
 int itemCount,
 long time)

key

protected long key(long time)

remove

public List<ImpressionAggregatorServiceTest.Impression> remove()

Returns:

All aggregated ImpressionAggregatorServiceTest.Impression excluding those in the current ongoing aggregationWindow.

removeInternal

protected List<ImpressionAggregatorServiceTest.Impression> removeInternal(long time)