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

Class WatermarkDurationEvictionPolicy<T>

java.lang.Object

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

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

All Implemented Interfaces:

IEvictionPolicy<T>

public class WatermarkDurationEvictionPolicy<T>
extends DurationEvictionPolicy<T>

Field Summary

Fields inherited from class edu.iu.dsc.tws.task.window.policy.eviction.duration.DurationEvictionPolicy

evictionContext, referenceTime

Constructor Summary

Constructors

Constructor and Description
WatermarkDurationEvictionPolicy(long winLength)
WatermarkDurationEvictionPolicy(long winLength, long lag)

Method Summary

Modifier and Type	Method and Description
Action	evict(Event<T> event)
java.lang.String	toString()

Methods inherited from class edu.iu.dsc.tws.task.window.policy.eviction.duration.DurationEvictionPolicy

setContext, track

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkDurationEvictionPolicy

public WatermarkDurationEvictionPolicy(long winLength)

WatermarkDurationEvictionPolicy

public WatermarkDurationEvictionPolicy(long winLength,
                                       long lag)

Method Detail

evict

public Action evict(Event<T> event)

Specified by:

evict in interface IEvictionPolicy<T>

Overrides:

evict in class DurationEvictionPolicy<T>

toString

public java.lang.String toString()

Overrides:

toString in class DurationEvictionPolicy<T>