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

Class WatermarkCountWindowPolicy<T>

java.lang.Object

edu.iu.dsc.tws.task.window.policy.trigger.count.CountWindowPolicy<T>

edu.iu.dsc.tws.task.window.policy.trigger.count.WatermarkCountWindowPolicy<T>

All Implemented Interfaces:

IWindowingPolicy<T>, java.io.Serializable

public class WatermarkCountWindowPolicy<T>
extends CountWindowPolicy<T>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WatermarkCountWindowPolicy(long count, IManager manager, IEvictionPolicy<T> evictionPolicy, WindowManager<T> winManager)

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

WatermarkCountWindowPolicy

public WatermarkCountWindowPolicy(long count,
                                  IManager manager,
                                  IEvictionPolicy<T> evictionPolicy,
                                  WindowManager<T> winManager)

Method Detail

validate

public boolean validate()

Specified by:

validate in interface IWindowingPolicy<T>

Overrides:

validate in class CountWindowPolicy<T>

whyInvalid

public java.lang.String whyInvalid()

Specified by:

whyInvalid in interface IWindowingPolicy<T>

Overrides:

whyInvalid in class CountWindowPolicy<T>

track

public void track(Event<T> event)

Specified by:

track in interface IWindowingPolicy<T>

Overrides:

track in class CountWindowPolicy<T>

reset

public void reset()

Specified by:

reset in interface IWindowingPolicy<T>

Overrides:

reset in class CountWindowPolicy<T>

start

public void start()

Specified by:

start in interface IWindowingPolicy<T>

Overrides:

start in class CountWindowPolicy<T>

shutdown

public void shutdown()

Specified by:

shutdown in interface IWindowingPolicy<T>

Overrides:

shutdown in class CountWindowPolicy<T>

toString

public java.lang.String toString()

Overrides:

toString in class CountWindowPolicy<T>