Package lupos.engine.operators

Examples of lupos.engine.operators.BasicOperator.addSucceedingOperator()

94
95
96
97
98
99
100
101
102
103
104
    final int index = genAdd.getOperatorIDTuple(projection).getId();

    BasicOperator pre;
    for (int i = 0; i < pres.size(); i++) {
      pre = pres.get(i);
      pre.addSucceedingOperator(new OperatorIDTuple(projection, index));
      pre.removeSucceedingOperator(genAdd);
      projection.addPrecedingOperator(pre);
    }

    projection.removePrecedingOperator(genAdd);
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
    // Connect all precessors to all successors
    for (int i = 0; i < pres.size(); i++) {
      for (int a = 0; a < succs.size(); a++) {
        idTuple = succs.get(a);
        pre = pres.get(i);
        pre.addSucceedingOperator(new OperatorIDTuple(idTuple
            .getOperator(), idTuple.getId()));
        pre.removeSucceedingOperator(projection);
      }
    }
View Full Code Here
87
88
89
90
91
92
93
94
95
96
97
    final int index = genAdd.getOperatorIDTuple(join).getId();

    BasicOperator pre;
    for (int i = 0; i < pres.size(); i++) {
      pre = pres.get(i);
      pre.addSucceedingOperator(new OperatorIDTuple(join, index));
      pre.removeSucceedingOperator(genAdd);
      join.addPrecedingOperator(pre);
    }

    join.removePrecedingOperator(genAdd);
View Full Code Here
84
85
86
87
88
89
90
91
92
93
94
    final int index = genAdd.getOperatorIDTuple(filter).getId();

    BasicOperator pre;
    for (int i = 0; i < pres.size(); i++) {
      pre = pres.get(i);
      pre.addSucceedingOperator(new OperatorIDTuple(filter, index));
      pre.removeSucceedingOperator(genAdd);
      filter.addPrecedingOperator(pre);
    }

    filter.removePrecedingOperator(genAdd);
View Full Code Here
56
57
58
59
60
61
62
63
64
65
66
      sso.addSucceedingOperator(sort);
    } else {
      sso.addSucceedingOperator(federatedQuery);
    }
    Join join = new Join();
    federatedQuery.addSucceedingOperator(join, 1);
    sso.addSucceedingOperator(join, 0);
    connection.connect(join);
    connection.setOperatorConnection(sso);
  }
View Full Code Here
128
129
130
131
132
133
134
135
136
137
138
    // deleted
    if (replaceLit.getSubstitutionsLiteralLeft().size() == 0) {
      BasicOperator pre;
      for (int i = 0; i < pres.size(); i++) {
        pre = pres.get(i);
        pre.addSucceedingOperator(new OperatorIDTuple(filter, index));
        pre.removeSucceedingOperator(replaceLit);
        filter.addPrecedingOperator(pre);
      }
      filter.removePrecedingOperator(replaceLit);
      deleted.add(replaceLit);
View Full Code Here
92
93
94
95
96
97
98
99
100
101
102
        .getSucceedingOperators();

    BasicOperator pre;
    for (int i = 0; i < pres.size(); i++) {
      pre = pres.get(i);
      pre.addSucceedingOperator(new OperatorIDTuple(replaceVar_new, 0));
      pre.removeSucceedingOperator(projection);
    }

    replaceVar_new.setPrecedingOperators(pres);
    replaceVar_new
View Full Code Here
129
130
131
132
133
134
135
136
137
138
139
    // deleted
    if (replaceLit.getSubstitutionsLiteralLeft().size() == 0) {
      BasicOperator pre;
      for (int i = 0; i < pres.size(); i++) {
        pre = pres.get(i);
        pre.addSucceedingOperator(new OperatorIDTuple(join, index));
        pre.removeSucceedingOperator(replaceLit);
        join.addPrecedingOperator(pre);
      }
      join.removePrecedingOperator(replaceLit);
      deleted.add(replaceLit);
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
            .getOperator(), generate.getValueOrVariable());
        added.add(generate_new);
        // connect the new one instead of the old Generate to the
        // predecessors
        generate_new.setPrecedingOperators(pres);
        pre.addSucceedingOperator(new OperatorIDTuple(generate_new, 0));
      }

      rootOperator.deleteParents();
      rootOperator.setParents();
      rootOperator.detectCycles();
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
      final List<BasicOperator> pres = (List<BasicOperator>) generate
          .getPrecedingOperators();
      BasicOperator pre;
      for (int i = 0; i < pres.size(); i++) {
        pre = pres.get(i);
        pre.addSucceedingOperator(new OperatorIDTuple(order.getFirst(),
            0));
        if (filter != null) {
          Collection<Variable> vars = filter
              .getIntersectionVariables();
          if (vars == null)
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.