edu.iu.dsc.tws.task.window.policy.eviction.count

Class WatermarkCountEvictionPolicy<T>

java.lang.Object

edu.iu.dsc.tws.task.window.policy.eviction.count.CountEvictionPolicy<T>

edu.iu.dsc.tws.task.window.policy.eviction.count.WatermarkCountEvictionPolicy<T>

All Implemented Interfaces:

IEvictionPolicy<T>

public class WatermarkCountEvictionPolicy<T>
extends CountEvictionPolicy<T>

Field Summary

Fields inherited from class edu.iu.dsc.tws.task.window.policy.eviction.count.CountEvictionPolicy

currentCount, threshold

Constructor Summary

Constructors

Constructor and Description
WatermarkCountEvictionPolicy(long count)

Method Summary

Modifier and Type	Method and Description
Action	evict(Event<T> event)
void	setContext(IEvictionContext context)
java.lang.String	toString()
void	track(Event<T> event)

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkCountEvictionPolicy

public WatermarkCountEvictionPolicy(long count)

Method Detail

evict

public Action evict(Event<T> event)

Specified by:

evict in interface IEvictionPolicy<T>

Overrides:

evict in class CountEvictionPolicy<T>

track

public void track(Event<T> event)

Specified by:

track in interface IEvictionPolicy<T>

Overrides:

track in class CountEvictionPolicy<T>

setContext

public void setContext(IEvictionContext context)

Specified by:

setContext in interface IEvictionPolicy<T>

Overrides:

setContext in class CountEvictionPolicy<T>

toString

public java.lang.String toString()

Overrides:

toString in class CountEvictionPolicy<T>