Examples of addSucceedingOperator()


Examples of lupos.engine.operators.singleinput.path.PathLengthZero.addSucceedingOperator()

      final PathLengthZero zeroOperator = new PathLengthZero(subject, object, allowedSubjects, allowedObjects);
      memoryScan.addSucceedingOperator(new OperatorIDTuple(zeroOperator,0));

      final Union union = new Union();
      zeroOperator.addSucceedingOperator(new OperatorIDTuple(union,0));
      startingOperator.addSucceedingOperator(new OperatorIDTuple(union,1));

      final InMemoryDistinct distinct = new InMemoryDistinct();
      union.addSucceedingOperator(new OperatorIDTuple(distinct,0));
View Full Code Here

Examples of lupos.engine.operators.singleinput.sort.ImmediateSort.addSucceedingOperator()

                vars.addAll(basicOperator
                    .getIntersectionVariables());
                immediateSort.setUnionVariables(vars);
                immediateSort.setIntersectionVariables(vars);
                immediateSort.addPrecedingOperator(bo);
                immediateSort
                .addSucceedingOperator(new OperatorIDTuple(
                    newOperator, bo
                    .getOperatorIDTuple(
                        newOperator)
                        .getId()));
View Full Code Here

Examples of lupos.engine.operators.singleinput.sort.Sort.addSucceedingOperator()

      LinkedList<Variable> listOfVars = new LinkedList<Variable>();
      listOfVars.add(new Variable(((ASTVar)child0).getName()));
      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);
    }
View Full Code Here

Examples of lupos.engine.operators.stream.Window.addSucceedingOperator()

      this.result.addApplication(cr);
      this.indexScanCreator_Stream.setStream(new StreamTriples(cr, 1));
    }
    this.indexScanCreator_Stream.getStream().addSucceedingOperator(new OperatorIDTuple(window, 0));
    final PatternMatcher currentPatternMatcher = new PatternMatcher();
    window.addSucceedingOperator(new OperatorIDTuple(currentPatternMatcher, 0));
    final PatternMatcher oldPatternMatcher = this.indexScanCreator_Stream.getCurrentPatternMatcher();
    this.indexScanCreator_Stream.setCurrentPatternMatcher(currentPatternMatcher);
    for (int i = 0; i < node.jjtGetNumChildren(); i++) {
      final Node n = node.jjtGetChild(i);
      if (!(n instanceof ASTType)) {
View Full Code Here

Examples of lupos.engine.operators.tripleoperator.TriggerOneTime.addSucceedingOperator()

                      .getUnionVariables());
                  lastOperator.addPrecedingOperator(add);
                  lastOperator = add;
                }
              }
              trigger.addSucceedingOperator(new OperatorIDTuple(
                  lastOperator, 0));
            }

            if (trigger.getSucceedingOperators().size() > 0) {
              trigger.setPrecedingOperators(tp
View Full Code Here

Examples of lupos.engine.operators.tripleoperator.TriplePattern.addSucceedingOperator()

    pat1.setSucceedingOperator(new OperatorIDTuple(repLit, 0));

    repLit.setPrecedingOperator(pat1);
    repLit.setSucceedingOperator(new OperatorIDTuple(succ, -1));

    pat2.addSucceedingOperator(new OperatorIDTuple(succ, -1));

    succ.setPrecedingOperator(repLit);
    succ.addPrecedingOperator(pat2);

    subGraphMap = new HashMap<BasicOperator, String>();
View Full Code Here

Examples of lupos.gui.operatorgraph.visualeditor.operators.Operator.addSucceedingOperator()

        if (n instanceof ASTFilterConstraint) {
          filterOp = (Operator) n.jjtAccept(
              this, data);

          if (filterOp != null) {
            filterOp.addSucceedingOperator(new OperatorIDTuple<Operator>(
                testOP, 0));

            testOP = filterOp;
          }
        }
View Full Code Here

Examples of lupos.gui.operatorgraph.visualeditor.queryeditor.operators.Construct.addSucceedingOperator()

    this.handleDatasetClause(node, c);
    this.handleSolutionModifier(node, c);

    final OperatorContainer constructTemplateOp = (OperatorContainer) node
    .jjtGetChild(0).jjtAccept(this, data);
    c.addSucceedingOperator(new OperatorIDTuple<Operator>(constructTemplateOp, 0));

    return c;
  }

  public Object visit(final ASTConstructTemplate node, final Object data) {
View Full Code Here

Examples of lupos.gui.operatorgraph.visualeditor.queryeditor.operators.Graph.addSucceedingOperator()

    for (int i = 1; i < numberChildren; i++) {
      final Operator op = (Operator) node.jjtGetChild(i).jjtAccept(
          this, data);

      g.addSucceedingOperator(new OperatorIDTuple<Operator>(op, i - 1));
    }

    return g;
  }
View Full Code Here

Examples of lupos.gui.operatorgraph.visualeditor.queryeditor.operators.Join.addSucceedingOperator()

              || n instanceof ASTGraphConstraint) {
            testOP = (Operator) n.jjtAccept(
                this, data);

            if (testOP != null) {
              joinOp.addSucceedingOperator(new OperatorIDTuple<Operator>(
                  testOP, j));
            }

            j++;
          }
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.