Example 6: Multiple parallel regions with differing fusion

The parallel transformation replicates operators A and B for the first parallel region, and operators C and D for the second parallel region. The Src operator is given two splitters, one to feed each parallel region. Fusion places the the Src operator, along with all siblings of operators A and B in one PE. Fusion places the siblings for operators C and D for each channel in their own PE. Fusion places the Snk operator into its own PE. Threaded ports are inserted between the output ports of one splitter and the replicas of operator A.

composite Comp6_1(input In; output B) {
  graph
    stream<Type> A = Functor(In) {}
    stream<Type> B = Functor(A) {}
}

composite Comp6_2(input In; output D) {
  graph
    stream<Type> C = Functor(In) {}
    stream<Type> D = Functor(C) {}
}

composite Main6 {
  graph
    stream<Type> Src = Source() {
      config placement: partitionColocation(“SrcAB”);
    }

    @parallel(width=2)
    stream<Type> Out_1 = Comp6_1(Src) {
      config placement: partitionColocation(“SrcAB”);
    }

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

    () as Snk = Sink(Out_1, Out_2) {
      config placement: partitionIsolation;
    }
}