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

Class DurationEvictionPolicy<T>

java.lang.Object

edu.iu.dsc.tws.task.window.policy.eviction.duration.DurationEvictionPolicy<T>

All Implemented Interfaces:

IEvictionPolicy<T>

Direct Known Subclasses:

WatermarkDurationEvictionPolicy

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

Field Summary

Fields

Modifier and Type	Field and Description
protected IEvictionContext	evictionContext
protected java.lang.Long	referenceTime

Constructor Summary

Constructors

Constructor and Description
DurationEvictionPolicy(long winLength)

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

referenceTime

protected java.lang.Long referenceTime

evictionContext

protected IEvictionContext evictionContext

Constructor Detail

DurationEvictionPolicy

public DurationEvictionPolicy(long winLength)

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