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 java.lang.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 java.util.Map<java.lang.String,java.util.Map<java.lang.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(java.lang.String scenarioId, int itemCount)
void	addImpression(java.lang.String scenarioId, int impressionCount, int itemCount, long time)
protected long	key(long time)
java.util.List<ImpressionAggregatorServiceTest.Impression>	remove()
protected java.util.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 Detail

window

protected int window

window_2

protected int window_2

counters

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

Constructor Detail

ImpressionAggregatorService

public ImpressionAggregatorService()

Method Detail

addImpression

public void addImpression(java.lang.String scenarioId,
                          int itemCount)

addImpression

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

key

protected long key(long time)

remove

public java.util.List<ImpressionAggregatorServiceTest.Impression> remove()

Returns:

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

removeInternal

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