basic.CountDecimateSimple Class Reference

Use the CountDecimate processor to discard events from a stream. More...

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

Detailed Description

Use the CountDecimate processor to discard events from a stream.

Graphically, this can be represented as follows:

The expected output of this program is:

0,3,6,9,

Author

Sylvain Hallé

Definition at line 38 of file CountDecimateSimple.java.

Member Function Documentation

main()

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

static

We create a CountDecimate processor and instruct it to keep one

Definition at line 40 of file CountDecimateSimple.java.

    {
        /// We create a CountDecimate processor and instruct it to keep one
        // event every 3
        CountDecimate dec = new CountDecimate(3);
        
        // 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 < 10; i++)
        {
            p.push(i);
        }
        ///
    }

---

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

• Source/src/basic/CountDecimateSimple.java