basic.WindowEven Class Reference

Use a Window processor to perform a computation over a sliding window of events that are not numeric. More...

Static Public Member Functions
static void	main (String[] args)

Detailed Description

Use a Window processor to perform a computation over a sliding window of events that are not numeric.

The chain of processors in this example can be represented graphically as:

Author

Sylvain Hallé Easy

Definition at line 40 of file WindowEven.java.

Member Function Documentation

main()

static void basic.WindowEven.main ( String []  args )

static

Create a source of arbitrary numbers

Definition at line 42 of file WindowEven.java.

    {
        /// Create a source of arbitrary numbers
        QueueSource source = new QueueSource().setEvents(2, 7, 1, 8, 2, 8, 1, 8, 2, 8);
        
        // Check if each number is even
        ApplyFunction is_even = new ApplyFunction(Numbers.isEven);
        Connector.connect(source, is_even);
        
        // Create a cumulate processor
        Cumulate sum = new Cumulate(
                new CumulativeFunction<Boolean>(Booleans.or));
        
        // Create a window processor of width 3, using sum as the
        // processor to be used on each window. Connect it to is_even.
        Window win = new Window(sum, 3);
        Connector.connect(is_even, win);
        
        // Pull events from the window
        Pullable p = win.getPullableOutput();
        for (int i = 0; i < 10; i++)
        {
            System.out.println("Window #" + i + ": " + p.pull());
        }
        ///
    }

---

The documentation for this class was generated from the following file:

• Source/src/basic/WindowEven.java