Example 10:Multiple PEs in a parallel channel

The parallel transformation replicates operators A, B and C. The Src operator is given a splitter. Fusion places the siblings of operators A and B for each channel in their own PE. Fusion places the siblings for operator C in their own PEs. The Src and Snk operators are given their own PEs.

composite Comp10(input In; output C) {
  graph
    stream<Type> A = Functor(In) {}
    stream<Type> B = Functor(A) {}
    stream<Type> C = Functor(B) {
      config placement: partitionColocation(byChannel());
    }
}

composite Main10 {
  graph
    stream<Type> Src = Source() {
      config placement: partitionIsolation;
    }

    @parallel(width=2)
    stream<Type> Out = Comp10(Src) {
      config placement: partitionColocation(byChannel());
    }

    () as Snk = Sink(Out) {
      config placement: partitionIsolation;
    }
}