org.apache.storm.windowing

Class TupleWindowImpl

java.lang.Object

org.apache.storm.windowing.TupleWindowImpl

All Implemented Interfaces:

TupleWindow, Window<Tuple>

public class TupleWindowImpl
extends Object
implements TupleWindow

Holds the expired, new and current tuples in a window.

Constructor Summary

Constructors

Constructor and Description
TupleWindowImpl(List<Tuple> tuples, List<Tuple> newTuples, List<Tuple> expiredTuples)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
List<Tuple>	get() Gets the list of events in the window.
List<Tuple>	getExpired() Get the list of events expired from the window since the last time the window was generated.
List<Tuple>	getNew() Get the list of newly added events in the window since the last time the window was generated.
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

TupleWindowImpl

public TupleWindowImpl(List<Tuple> tuples,
                       List<Tuple> newTuples,
                       List<Tuple> expiredTuples)

Method Detail

get

public List<Tuple> get()

Description copied from interface: Window

Gets the list of events in the window.

Specified by:

get in interface Window<Tuple>

Returns:

the list of events in the window.

getNew

public List<Tuple> getNew()

Description copied from interface: Window

Get the list of newly added events in the window since the last time the window was generated.

Specified by:

getNew in interface Window<Tuple>

Returns:

the list of newly added events in the window.

getExpired

public List<Tuple> getExpired()

Description copied from interface: Window

Get the list of events expired from the window since the last time the window was generated.

Specified by:

getExpired in interface Window<Tuple>

Returns:

the list of events expired from the window.

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object