basic.DuplicateContext Class Reference

Duplicating processors and observing what happens to their Context object. More...

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

Detailed Description

Duplicating processors and observing what happens to their Context object.

Author

Sylvain Hallé Easy

Definition at line 36 of file DuplicateContext.java.

Member Function Documentation

main()

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

static

We first create an ApplyFunction that simply adds

Definition at line 38 of file DuplicateContext.java.

  {
    /// We first create an ApplyFunction that simply adds
    // the value of some context element to the current event
    ApplyFunction f1 = new ApplyFunction(new FunctionTree(
        Numbers.addition, StreamVariable.X, new ContextVariable("foo")));
    Connector.connect(f1, new Print()
        .setPrefix("f1: ").setSeparator("\n"));

    // We then feed a few events to each of them
    Pushable p_f1 = f1.getPushableInput();
    f1.setContext("foo", 10);
    p_f1.push(3).push(1);
    
    // Let us now duplicate sum1 and push events to the copy
    ApplyFunction f2 = (ApplyFunction) f1.duplicate();
    Connector.connect(f2, new Print()
        .setPrefix("f2: ").setSeparator("\n"));
    Pushable p_f2 = f2.getPushableInput();
    p_f2.push(2).push(7).push(1);
    ///
  }

---

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

• Source/src/basic/DuplicateContext.java