Examples of addSucceedingOperator()

Examples of lupos.distributed.operator.SubgraphContainer.addSucceedingOperator()

550
551
552
553
554
555
556
557
558
559
560
           * container in the join-operator in the 1st subgraph
           * container
           */
          bis.addSucceedingOperator(smallJoin, 0);
          smallJoin.addPrecedingOperator(sg2);
          sg2.addSucceedingOperator(smallJoin, 1);
          smallJoin.addPrecedingOperator(bis);
          /*
           * now connect the join with the succeeding operators of the
           * old basic index scan (here we use the hack, to clone the
           * succeeding list of the index scan, because when we
View Full Code Here

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

150
151
152
153
154
155
156
157
158
159
160
        final BasicOperator cloneNew = toCloneNew.clone();
        final OperatorIDTuple oid = toCloneNew
            .getOperatorIDTuple(toClone);
        cloneNew.removeSucceedingOperator(toClone);
        // try {
        cloneNew.addSucceedingOperator(new OperatorIDTuple(clone, oid
            .getId()));
        // } catch (final Exception e) {
        // System.out.println("2");
        // }
        clone.removePrecedingOperator(toCloneNew);
View Full Code Here

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

71
72
73
74
75
76
77
78
79
80
81
    final int index = genAdd.getOperatorIDTuple(union).getId();

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

    union.removePrecedingOperator(genAdd);
View Full Code Here

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

98
99
100
101
102
103
104
105
106
107
108
    // Connect the ReplaceLit precessors directly to the Projection
    for (int i = pres.size() - 1; i >= 0; i--) {
      pre = pres.get(i);
      projection.addPrecedingOperator(pre);
      pre.removeSucceedingOperator(replaceLit);
      pre.addSucceedingOperator(new OperatorIDTuple(projection, index));
    }

    // Make ReplaceLit the successor of Projection
    projection.removePrecedingOperator(replaceLit);
    projection.setSucceedingOperator(new OperatorIDTuple(replaceLit, 0));
View Full Code Here

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

75
76
77
78
79
80
81
82
83
84
85
    // Connect the precessors of the ReplaceLit directly to the Union
    for (int i = 0; i < pres.size(); i++) {
      pre = pres.get(i);
      union.addPrecedingOperator(pre);
      pre.removeSucceedingOperator(replaceLit);
      pre.addSucceedingOperator(new OperatorIDTuple(union, index));
    }
    union.removePrecedingOperator(replaceLit);

    // ReplaceLit becomes the new sucessor of Union
    union.setSucceedingOperator(new OperatorIDTuple(replaceLit, 0));
View Full Code Here

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

71
72
73
74
75
76
77
78
79
80
81
    OperatorIDTuple idTuple;
    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(generateAdd);
      }
    }
View Full Code Here

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

89
90
91
92
93
94
95
96
97
98
99
        .getSucceedingOperators();

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

    optional.removePrecedingOperator(genAdd);
View Full Code Here

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

110
111
112
113
114
115
116
117
118
119
120
    // Set precessors
    BasicOperator pre;
    for (int i = 0; i < pres.size(); i++) {
      pre = pres.get(i);
      pre.addSucceedingOperator(new OperatorIDTuple(rep_new, pre
          .getOperatorIDTuple(rep1).getId()));
      pre.removeSucceedingOperator(rep1);
    }

    rep_new.setPrecedingOperators(pres);
View Full Code Here

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

72
73
74
75
76
77
78
79
80
81
82
    // 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(replaceLit);
      }
    }
View Full Code Here

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

96
97
98
99
100
101
102
103
104
105
106
      HashSet<Variable> joinIntersection = new HashSet<Variable>(firstOperand.getUnionVariables());
      joinIntersection.retainAll(secondOperand.getUnionVariables());
      join.setIntersectionVariables(joinIntersection);
           
      firstOperand.addSucceedingOperator(join, 0);
      secondOperand.addSucceedingOperator(join, 1);
     
      jointree.add(new Tuple<BasicOperator, T>(join, mergeInitialInformations(firstSubGraph.getSecond(), secondSubGraph.getSecond())));     
    }
   
    BasicOperator op = jointree.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.