com.scaleoutsoftware.streaming.timewindowing

Class Windowing

java.lang.Object

com.scaleoutsoftware.streaming.timewindowing.Windowing

public class Windowing
extends java.lang.Object

Static functions that transform a List into an iterable collection of TimeWindows.

Constructor Summary

Constructors

Constructor and Description
Windowing()

Method Summary

Modifier and Type	Method and Description
static <T> java.lang.Iterable<TimeWindow<T>>	toSessionWindows(java.util.List<T> source, TimestampSelector<T> selector, long start, long end, long timeout) Transforms a List into an iterable collection of session TimeWindows.
static <T> java.lang.Iterable<TimeWindow<T>>	toSlidingWindows(java.util.List<T> source, TimestampSelector<T> selector, long start, long end, long duration, long every) Transforms a List into an iterable collection of sliding TimeWindows
static <T> java.lang.Iterable<TimeWindow<T>>	toTumblingWindows(java.util.List<T> source, TimestampSelector<T> selector, long start, long end, long duration) Transforms a List into an iterable collection of tumbling TimeWindows.

Methods inherited from class java.lang.Object

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

Constructor Detail

Windowing

public Windowing()

Method Detail

toSessionWindows

public static <T> java.lang.Iterable<TimeWindow<T>> toSessionWindows(java.util.List<T> source,
                                                                     TimestampSelector<T> selector,
                                                                     long start,
                                                                     long end,
                                                                     long timeout)

Transforms a List into an iterable collection of session TimeWindows.

Type Parameters:

T - the type of objects in the source collection

Parameters:

source - the source collection

selector - the selector used to pull timestamps from objects

start - the start time to use when scanning the collection

timeout - the minimum amount of time between session window ranges

end - the end time to use when scanning the collection

Returns:

an iterable collection of session windows

toTumblingWindows

public static <T> java.lang.Iterable<TimeWindow<T>> toTumblingWindows(java.util.List<T> source,
                                                                      TimestampSelector<T> selector,
                                                                      long start,
                                                                      long end,
                                                                      long duration)

Transforms a List into an iterable collection of tumbling TimeWindows.

Type Parameters:

T - the type of objects in the source collection

Parameters:

source - the source collection

selector - the selector used to pull timestamps from objects

start - the start time to use when scanning the collection

end - the end time to use when scanning the collection

duration - the length of time in each time window

Returns:

an iterable collection of tumbling windows

toSlidingWindows

public static <T> java.lang.Iterable<TimeWindow<T>> toSlidingWindows(java.util.List<T> source,
                                                                     TimestampSelector<T> selector,
                                                                     long start,
                                                                     long end,
                                                                     long duration,
                                                                     long every)

Transforms a List into an iterable collection of sliding TimeWindows

Type Parameters:

T - the type of objects in the source collection

Parameters:

source - the source collection

selector - the selector used to pull timestamp from objects

start - the start time to use when scanning the collection

end - the end time to use when scanning the collection

duration - the length of time in each time window

every - the time between the starting point of each time window

Returns:

an iterable collection of sliding windows