basic.CountDecimateLast Class Reference

Behaviour of the CountDecimate processor on the last event of a stream. More...

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

Detailed Description

Behaviour of the CountDecimate processor on the last event of a stream.

The expected output of this program is:

0,3,6,9,

Author

Sylvain Hallé

Definition at line 35 of file CountDecimateLast.java.

Member Function Documentation

main()

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

static

We create a CountDecimate processor and instruct it to keep one

Definition at line 37 of file CountDecimateLast.java.

    {
        /// We create a CountDecimate processor and instruct it to keep one
        // event every 3
        CountDecimate dec = new CountDecimate(3, true);
        
        // We connect dec to a Print processor
        Print print = new Print();
        Connector.connect(dec, print);
        
        // We get a hold of dec's Pushable object and push the integers
        // 0 to 9. 
        Pushable p = dec.getPushableInput();
        for (int i = 0; i < 8; i++)
        {
            p.push(i);
        }
        p.notifyEndOfTrace();
        ///
    }

---

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

• Source/src/basic/CountDecimateLast.java