org.deri.cqels.engine

Class RangeWindow

java.lang.Object

org.deri.cqels.engine.RangeWindow

All Implemented Interfaces:

Window

Direct Known Subclasses:

All

public class RangeWindow
extends java.lang.Object
implements Window

This class implements the time-based window

Author:

Danh Le Phuoc, Chan Le Van

Constructor Summary

Constructors

Constructor and Description
RangeWindow(DurationSet durations, Duration slideDuration)
RangeWindow(long w)
RangeWindow(long w, long slide)

Method Summary

Methods

Modifier and Type	Method and Description
RangeWindow	clone()
void	enableSlidePurifier(Purifier p)
long	getDuration()
long	getSlide()
void	purge() This method will purify a number of expired elements in the window according to its characteristics (triple-based or time-based windows)
void	purge(long timeRange, java.lang.String message)
void	report(long t)
void	reportLatestTime(long t)
void	setBuff(Database db) each window has a buffer to store elements.

Methods inherited from class java.lang.Object

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

Constructor Detail

RangeWindow

public RangeWindow(long w)

RangeWindow

public RangeWindow(long w,
           long slide)

RangeWindow

public RangeWindow(DurationSet durations,
           Duration slideDuration)

Method Detail

enableSlidePurifier

public void enableSlidePurifier(Purifier p)

setBuff

public void setBuff(Database db)

Description copied from interface: Window

each window has a buffer to store elements. This method sets it to current window

Specified by:

setBuff in interface Window

Parameters:

db - database-type buffer

getSlide

public long getSlide()

getDuration

public long getDuration()

purge

public void purge(long timeRange,
         java.lang.String message)

purge

public void purge()

Description copied from interface: Window

This method will purify a number of expired elements in the window according to its characteristics (triple-based or time-based windows)

Specified by:

purge in interface Window

reportLatestTime

public void reportLatestTime(long t)

Specified by:

reportLatestTime in interface Window

report

public void report(long t)

clone

public RangeWindow clone()

Specified by:

clone in interface Window

Overrides:

clone in class java.lang.Object