slidingWindow: Sliding window function example

In RcppStreams: 'Rcpp' Integration of the 'Streamulus' 'DSEL' for Stream Processing

Description

This is an example function illustrating Streamulus

Usage

slidingWindow()

Value

An unconditional TRUE value

Author(s)

Dirk Eddelbuettel

Examples

## Not run: 
slidingWindow()

## End(Not run)

Example output

Work called. mQueue.size() = 1
-------------   TS <-- 0   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 1   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 2   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 3   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 4   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 0   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 1   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 2   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 3   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 4   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 0   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 1   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 2   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 3   -------------
Work called. mQueue.size() = 0
-------------   TS <-- 4   -------------
Work called. mQueue.size() = 0
[1] TRUE

RcppStreams documentation built on May 2, 2019, 10:17 a.m.