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

Class DurationWindowPolicy<T>

java.lang.Object

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

All Implemented Interfaces:

IWindowingPolicy<T>, java.io.Serializable

Direct Known Subclasses:

WatermarkDurationWindowPolicy

public class DurationWindowPolicy<T>
extends java.lang.Object
implements IWindowingPolicy<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DurationWindowPolicy(long millis, IManager<T> mgr, IEvictionPolicy<T> policy)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

DurationWindowPolicy

public DurationWindowPolicy(long millis,
                            IManager<T> mgr,
                            IEvictionPolicy<T> policy)

Method Detail

validate

public boolean validate()

Specified by:

validate in interface IWindowingPolicy<T>

whyInvalid

public java.lang.String whyInvalid()

Specified by:

whyInvalid in interface IWindowingPolicy<T>

track

public void track(Event<T> event)

Specified by:

track in interface IWindowingPolicy<T>

reset

public void reset()

Specified by:

reset in interface IWindowingPolicy<T>

start

public void start()

Specified by:

start in interface IWindowingPolicy<T>

shutdown

public void shutdown()

Specified by:

shutdown in interface IWindowingPolicy<T>

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object