Package lupos.engine.operators.singleinput

Examples of lupos.engine.operators.singleinput.SeveralSucceedingOperators.addSucceedingOperator()

51
52
53
54
55
56
57
58
59
60
61
      ComparatorVariables comparator = new ComparatorVariables(listOfVars);
      sort.setComparator(comparator);
      Group group = new Group(comparator);
      sort.addSucceedingOperator(group);
      group.addSucceedingOperator(federatedQuery);
      sso.addSucceedingOperator(sort);
    } else {
      sso.addSucceedingOperator(federatedQuery);
    }
    Join join = new Join();
    federatedQuery.addSucceedingOperator(join, 1);
View Full Code Here
53
54
55
56
57
58
59
60
61
62
63
      Group group = new Group(comparator);
      sort.addSucceedingOperator(group);
      group.addSucceedingOperator(federatedQuery);
      sso.addSucceedingOperator(sort);
    } else {
      sso.addSucceedingOperator(federatedQuery);
    }
    Join join = new Join();
    federatedQuery.addSucceedingOperator(join, 1);
    sso.addSucceedingOperator(join, 0);
    connection.connect(join);
View Full Code Here
57
58
59
60
61
62
63
64
65
66
67
    } else {
      sso.addSucceedingOperator(federatedQuery);
    }
    Join join = new Join();
    federatedQuery.addSucceedingOperator(join, 1);
    sso.addSucceedingOperator(join, 0);
    connection.connect(join);
    connection.setOperatorConnection(sso);
  }

  protected abstract FederatedQuery getFederatedQuery(ASTService node);
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
    Node child0 = node.jjtGetChild(0);
    if (child0 instanceof ASTVar) {
      Join join = new Join();
      connection.connect(join);
      SeveralSucceedingOperators sso = new SeveralSucceedingOperators();
      sso.addSucceedingOperator(join, 0);
      FederatedQueryTrivialApproach federatedQuery = new FederatedQueryTrivialApproach(node);
      Projection projection = new Projection();
      projection.addProjectionElement(new Variable(((ASTVar)child0).getName()));
      Distinct distinct = new Distinct();
      projection.addSucceedingOperator(distinct);
View Full Code Here
63
64
65
66
67
68
69
70
71
72
73
      Projection projection = new Projection();
      projection.addProjectionElement(new Variable(((ASTVar)child0).getName()));
      Distinct distinct = new Distinct();
      projection.addSucceedingOperator(distinct);
      distinct.addSucceedingOperator(federatedQuery);
      sso.addSucceedingOperator(projection, 0);
      federatedQuery.addSucceedingOperator(join, 1);
      connection.setOperatorConnection(sso);
    }   
  }
}
View Full Code Here
175
176
177
178
179
180
181
182
183
184
185
      connection.connect(muo);
    }
    if(ops.size()>1){
      SeveralSucceedingOperators endOp = new SeveralSucceedingOperators();
      for(Tuple<Construct, Item> entry: graphConstraints){
        endOp.addSucceedingOperator(entry.getFirst());
      }
      connection.setOperatorConnection(endOp);
    } else {
      connection.setOperatorConnection(graphConstraints.get(0).getFirst());
    }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.