edu.iu.dsc.tws.task.window.manage

Class WindowManager<T>

java.lang.Object

edu.iu.dsc.tws.task.window.manage.WindowManager<T>

All Implemented Interfaces:

IManager<T>, java.io.Serializable

public class WindowManager<T>
extends java.lang.Object
implements IManager<T>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static int	EXPIRE_EVENTS_THRESHOLD

Constructor Summary

Constructors

Constructor and Description
WindowManager()
WindowManager(WindowLifeCycleListener<T> windowLifeCycleListener)

Method Summary

Modifier and Type	Method and Description
void	add(Event<T> windowEvent)
void	add(IMessage<T> message)
void	add(IMessage<T> message, long ts)
IWindowMessage<T>	bundleExpiredWindowIMessage(java.util.List<IMessage<T>> events) This method bundles data into a IWindowMessage for creating expired IWindowMessages
IWindowMessage<T>	bundleNonExpiredWindowIMessage(java.util.List<IMessage<T>> events) This method bundles data into a IWindowMessage for creating non-expired IWindowMessages
IWindowMessage<T>	bundleWindowMessage(java.util.List<Event<T>> events)
void	compactWindow()
long	getEarliestEventTimestamp(long start, long end) provides the event with earliest timestamp between end and start timestamps by scanning through the queue of messages.
long	getEventCount(long referenceTime) This method returns the number of event count which has the timestamp lesser than the reference timestamp
IEvictionPolicy<T>	getEvictionPolicy()
java.util.List<java.lang.Long>	getSlidingCountTimestamps(long start, long end, long slide) This method is scanning the list of events falling under a given starting and end time stamp
IWindowingPolicy<T>	getWindowingPolicy()
boolean	onEvent()
java.util.List<Event<T>>	scanEvents(boolean fullScan)
void	setEvictionPolicy(IEvictionPolicy<T> evictionPolicy)
void	setWindowingPolicy(IWindowingPolicy<T> windowingPolicy)
void	shutdown()
void	track(Event<T> windowEvent)

Methods inherited from class java.lang.Object

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

Field Detail

EXPIRE_EVENTS_THRESHOLD

public static final int EXPIRE_EVENTS_THRESHOLD

See Also:

Constant Field Values

Constructor Detail

WindowManager

public WindowManager(WindowLifeCycleListener<T> windowLifeCycleListener)

WindowManager

public WindowManager()

Method Detail

getWindowingPolicy

public IWindowingPolicy<T> getWindowingPolicy()

setWindowingPolicy

public void setWindowingPolicy(IWindowingPolicy<T> windowingPolicy)

getEvictionPolicy

public IEvictionPolicy<T> getEvictionPolicy()

setEvictionPolicy

public void setEvictionPolicy(IEvictionPolicy<T> evictionPolicy)

add

public void add(IMessage<T> message)

Specified by:

add in interface IManager<T>

add

public void add(IMessage<T> message,
                long ts)

add

public void add(Event<T> windowEvent)

onEvent

public boolean onEvent()

Specified by:

onEvent in interface IManager<T>

scanEvents

public java.util.List<Event<T>> scanEvents(boolean fullScan)

bundleWindowMessage

public IWindowMessage<T> bundleWindowMessage(java.util.List<Event<T>> events)

bundleNonExpiredWindowIMessage

public IWindowMessage<T> bundleNonExpiredWindowIMessage(java.util.List<IMessage<T>> events)

This method bundles data into a IWindowMessage for creating non-expired IWindowMessages

Parameters:

events - list of elements that need to be passed into a window

Returns:

a bundled IWindowMessage considering a list of IMessages of a given data type

bundleExpiredWindowIMessage

public IWindowMessage<T> bundleExpiredWindowIMessage(java.util.List<IMessage<T>> events)

This method bundles data into a IWindowMessage for creating expired IWindowMessages

Parameters:

events - list of elements that need to be passed into a window

Returns:

a bundled IWindowMessage considering a list of IMessages of a given data type

track

public void track(Event<T> windowEvent)

compactWindow

public void compactWindow()

shutdown

public void shutdown()

getSlidingCountTimestamps

public java.util.List<java.lang.Long> getSlidingCountTimestamps(long start,
                                                                long end,
                                                                long slide)

This method is scanning the list of events falling under a given starting and end time stamp

Parameters:

start - the starting timestamp

end - the end time stamp

slide - the sliding interval count

Returns:

this list of events with time stamps

getEventCount

public long getEventCount(long referenceTime)

This method returns the number of event count which has the timestamp lesser than the reference timestamp

Parameters:

referenceTime - timestamp to which we compare the event time to filter them out

Returns:

the number of event count which is less than or equal to the reference time

getEarliestEventTimestamp

public long getEarliestEventTimestamp(long start,
                                      long end)

provides the event with earliest timestamp between end and start timestamps by scanning through the queue of messages.

Parameters:

start - starting timestamp (excluded for calculation)

end - ending timestamp (included for calculation)

Returns:

the minimum timestamp the queue between start and end