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

Class WindowingPolicy<T>

java.lang.Object

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

All Implemented Interfaces:

IWindowingPolicy<T>, java.io.Serializable

Direct Known Subclasses:

WindowingGlobalPolicy, WindowingSessionPolicy, WindowingSlidingPolicy, WindowingTumblingPolicy

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

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
WindowingPolicy(WindowType windowType, WindowConfig.Count count)
WindowingPolicy(WindowType windowType, WindowConfig.Duration duration)

Method Summary

Modifier and Type	Method and Description
WindowConfig.Count	getCount()
WindowConfig.Duration	getDuration()
WindowType	getWindowType()
void	reset()
void	shutdown()
void	start()
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, toString, wait, wait, wait

Constructor Detail

WindowingPolicy

public WindowingPolicy(WindowType windowType,
                       WindowConfig.Count count)

WindowingPolicy

public WindowingPolicy(WindowType windowType,
                       WindowConfig.Duration duration)

Method Detail

getWindowType

public WindowType getWindowType()

getCount

public WindowConfig.Count getCount()

getDuration

public WindowConfig.Duration getDuration()

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>