Project(Extend(Extend(Extend(Extend(Extend(Extend(AggregationJoin(Aggregation(??agg1: ?pid, SAMPLE,
                                                                  {},
                                                                  G1=Group((?pid,
                                                                     ?cond),
                                                                     Join(ToMultiSet({{(?pid, <http://www.example.com/products/Rl5RVl5R>)},
                                                                          {(?pid, <http://www.example.com/products/Rl5RVl5Q>)}, 
                                                                          {(?pid, <http://www.example.com/products/Rl5RVl5W>)}, 
                                                                          {(?pid, <http://www.example.com/products/Rl5RVl5Y>)}, 
                                                                          {(?pid, <http://www.example.com/products/Rl5RVl5U>)}}),
                                                                     Extend(Extend(BGP( ?pid ^<http://www.example.com/datam/op/isOfferOf> ?offid .
                                                                                    ?offid <http://www.example.com/datam/dp/condition> ?cond .
                                                                                    ?offid <http://www.example.com/datam/dp/price> ?price),
                                                                            ?newIncrement,
                                                                            if((?cond = 1), 0, 1) ),
                                                                     ?oldIncrement,
                                                                     if((?cond = 1), 1, 0) )))),
                                                  Aggregation(??agg2: ?cond, SAMPLE,
                                                  {}, G1),
                                                  Aggregation(??agg3: ?offid, SAMPLE,
                                                  {}, G1),
                                                  Aggregation(??agg4: ?price, MIN,
                                                  {}, G1),
                                                  Aggregation(??agg5: ?newIncrement, SUM,
                                                  {}, G1),
                                                  Aggregation(??agg6: ?oldIncrement, SUM,
                                                  {}, G1)),
                                           ?pid,
                                           ??agg1),
                                           ?cond,
                                           ??agg2),
                                    ?oid,
                                    ??agg3),
                             ?minPrice,
                             ??agg4),
                      ?newOffs,
                      ??agg5),
               ?usedOffs,
               ??agg6),
        {?pid, ?cond, ?oid, ?minPrice, ?newOffs, ?usedOffs})