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

Class CountEvictionPolicy<T>

java.lang.Object

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

All Implemented Interfaces:

IEvictionPolicy<T>

Direct Known Subclasses:

WatermarkCountEvictionPolicy

public class CountEvictionPolicy<T>
extends java.lang.Object
implements IEvictionPolicy<T>

Field Summary

Fields

Modifier and Type	Field and Description
protected java.util.concurrent.atomic.AtomicLong	currentCount
protected long	threshold

Constructor Summary

Constructors

Constructor and Description
CountEvictionPolicy(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

Field Detail

threshold

protected final long threshold

currentCount

protected final java.util.concurrent.atomic.AtomicLong currentCount

Constructor Detail

CountEvictionPolicy

public CountEvictionPolicy(long count)

Method Detail

evict

public Action evict(Event<T> event)

Specified by:

evict in interface IEvictionPolicy<T>

track

public void track(Event<T> event)

Specified by:

track in interface IEvictionPolicy<T>

setContext

public void setContext(IEvictionContext context)

Specified by:

setContext in interface IEvictionPolicy<T>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object