org.openimaj.util.stream.window

Class RealTimeWindowFunction<IN>

java.lang.Object

org.openimaj.util.stream.window.RealTimeWindowFunction<IN>

Type Parameters:

IN -

All Implemented Interfaces:

Function<Stream<IN>,Stream<Window<IN,Long>>>

public class RealTimeWindowFunction<IN>
extends Object
implements Function<Stream<IN>,Stream<Window<IN,Long>>>

Given a period of time to wait in milliseconds, this function consumes a stream for that period of time and produces a new stream of lists representing windows of that time period

Author:

Sina Samangooei (ss@ecs.soton.ac.uk)

Constructor Summary

Constructors

Constructor and Description
RealTimeWindowFunction(long waitTime)

Method Summary

Modifier and Type	Method and Description
Stream<Window<IN,Long>>	apply(Stream<IN> inner) Apply the function to the input argument and return the result.

Methods inherited from class java.lang.Object

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

Constructor Detail

RealTimeWindowFunction

public RealTimeWindowFunction(long waitTime)

Parameters:

waitTime -

Method Detail

apply

public Stream<Window<IN,Long>> apply(Stream<IN> inner)

Description copied from interface: Function

Apply the function to the input argument and return the result.

Specified by:

apply in interface Function<Stream<IN>,Stream<Window<IN,Long>>>

Parameters:

inner - the input object

Returns:

the result of the function