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

Class CountWindowPolicy<T>

java.lang.Object

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

All Implemented Interfaces:

IWindowingPolicy<T>, java.io.Serializable

Direct Known Subclasses:

WatermarkCountWindowPolicy

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CountWindowPolicy(long count, IManager manager, IEvictionPolicy<T> evictionPolicy)

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

CountWindowPolicy

public CountWindowPolicy(long count,
                         IManager manager,
                         IEvictionPolicy<T> evictionPolicy)

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