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

Class WatermarkDurationWindowPolicy<T>

java.lang.Object

edu.iu.dsc.tws.task.window.policy.trigger.duration.DurationWindowPolicy<T>

edu.iu.dsc.tws.task.window.policy.trigger.duration.WatermarkDurationWindowPolicy<T>

All Implemented Interfaces:

IWindowingPolicy<T>, java.io.Serializable

public class WatermarkDurationWindowPolicy<T>
extends DurationWindowPolicy<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WatermarkDurationWindowPolicy(long slidingInterval, IManager manager, WindowManager<T> windowManager, IEvictionPolicy<T> evictionPolicy)

Method Summary

Modifier and Type	Method and Description
void	reset()
void	shutdown()
void	start()
void	track(Event<T> event)
boolean	validate()
java.lang.String	whyInvalid()

Methods inherited from class edu.iu.dsc.tws.task.window.policy.trigger.duration.DurationWindowPolicy

toString

Methods inherited from class java.lang.Object

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

Constructor Detail

WatermarkDurationWindowPolicy

public WatermarkDurationWindowPolicy(long slidingInterval,
                                     IManager manager,
                                     WindowManager<T> windowManager,
                                     IEvictionPolicy<T> evictionPolicy)

Method Detail

validate

public boolean validate()

Specified by:

validate in interface IWindowingPolicy<T>

Overrides:

validate in class DurationWindowPolicy<T>

whyInvalid

public java.lang.String whyInvalid()

Specified by:

whyInvalid in interface IWindowingPolicy<T>

Overrides:

whyInvalid in class DurationWindowPolicy<T>

track

public void track(Event<T> event)

Specified by:

track in interface IWindowingPolicy<T>

Overrides:

track in class DurationWindowPolicy<T>

reset

public void reset()

Specified by:

reset in interface IWindowingPolicy<T>

Overrides:

reset in class DurationWindowPolicy<T>

start

public void start()

Specified by:

start in interface IWindowingPolicy<T>

Overrides:

start in class DurationWindowPolicy<T>

shutdown

public void shutdown()

Specified by:

shutdown in interface IWindowingPolicy<T>

Overrides:

shutdown in class DurationWindowPolicy<T>