List of addSucceedingOperator() Examples

Examples of addSucceedingOperator()

Examples of lupos.engine.operators.multiinput.join.Join.addSucceedingOperator()

      final Filter f2 = new Filter(filter2);
      final Generate g = new Generate(tp, a, b, c);
      final Join join = new Join();
      f1.addSucceedingOperator(new OperatorIDTuple(join, 0));
      f2.addSucceedingOperator(new OperatorIDTuple(join, 1));
      join.addSucceedingOperator(new OperatorIDTuple(g, 0));
      tp1.setSucceedingOperator(new OperatorIDTuple(f1, 0));
      tp2.setSucceedingOperator(new OperatorIDTuple(f2, 0));
      final Collection<TriplePattern> ctp1 = new LinkedList<TriplePattern>();
      ctp1.add(tp1);
      ic.addSucceedingOperator(new OperatorIDTuple(ic.newIndexScan(

View Full Code Here

Examples of lupos.engine.operators.multiinput.join.Join.addSucceedingOperator()

    try {
      final Filter f1 = new Filter(filter1);
      final Generate g = new Generate(tp, a, b, c);
      final Join join = new Join();
      f1.addSucceedingOperator(new OperatorIDTuple(join, 0));
      join.addSucceedingOperator(new OperatorIDTuple(g, 0));
      tp1.setSucceedingOperator(new OperatorIDTuple(f1, 0));
      tp2.setSucceedingOperator(new OperatorIDTuple(join, 1));
      final Collection<TriplePattern> ctp1 = new LinkedList<TriplePattern>();
      ctp1.add(tp1);
      ic.addSucceedingOperator(new OperatorIDTuple(ic.newIndexScan(

View Full Code Here

Examples of lupos.engine.operators.multiinput.minus.Minus.addSucceedingOperator()

    projection.addProjectionElement(subject);
    projection.addProjectionElement(object);
    if(graphConstraint!=null && graphConstraint.isVariable() && !graphConstraint.equals(getItem(subjectNode)) && !graphConstraint.equals(getItem(objectNode))) {
      projection.addProjectionElement((Variable)graphConstraint);
    }
    minus.addSucceedingOperator(new OperatorIDTuple(projection,0));


    return projection;
  }


  @Override

View Full Code Here

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

              for (int i = 0; i < 3; i++) {
                if (tp.getPos(i).isVariable()) {
                  final AddBinding add = new AddBinding(
                      (Variable) tp.getPos(i), t
                          .getPos(i));
                  add
                      .addSucceedingOperator(new OperatorIDTuple(
                          lastOperator, 0));
                  // Not completely correct, but for
                  // the succeeding optimization steps
                  // enough!

View Full Code Here

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

      final ASTVar n = new ASTVar(100);
      n.setName(subject.toString().substring(1));
      final Bind bind = new Bind(subject);
      bind.addProjectionElement(object,n);
      union.addSucceedingOperator(new OperatorIDTuple(bind,0));
      bind.addSucceedingOperator(new OperatorIDTuple(projection,0));
      final InMemoryDistinct memoryDistinct = new InMemoryDistinct();
      projection.addSucceedingOperator(new OperatorIDTuple(memoryDistinct,0));
      return memoryDistinct;
    }
  }

View Full Code Here

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

        // Inserting the join operation
        final ComputeBindings computeBindings = new ComputeBindings(this.getQueryResultFromValuesClause((ASTBindings)node.jjtGetChild(i)));
        final Join join = new Join();
        join.addSucceedingOperator(this.result);


        computeBindings.addSucceedingOperator(new OperatorIDTuple(join,1));


        this.indexScanCreator.createEmptyIndexScanAndConnectWithRoot(new OperatorIDTuple(computeBindings, 0));
        lastOperator = join;
      }
    }

View Full Code Here

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

        cu = new LinkedList<URILiteral>();
        cu.add((URILiteral)entry.getSecond());
      }
      muo.setURIs(cu);
      Construct construct=entry.getFirst();
      construct.addSucceedingOperator(muo);
      connection.connect(muo);
    }
    if(ops.size()>1){
      SeveralSucceedingOperators endOp = new SeveralSucceedingOperators();
      for(Tuple<Construct, Item> entry: graphConstraints){

View Full Code Here

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

      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);
    }
    Join join = new Join();

View Full Code Here

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

      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);
      distinct.addSucceedingOperator(federatedQuery);
      sso.addSucceedingOperator(projection, 0);
      federatedQuery.addSucceedingOperator(join, 1);
      connection.setOperatorConnection(sso);
    }

View Full Code Here

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

        replaceVar.addSucceedingOperator(new OperatorIDTuple(memoryDistinct,0));
        memoryDistinct.addSucceedingOperator(new OperatorIDTuple(intermediateJoinOperator,1));
        filter.addSucceedingOperator(new OperatorIDTuple(intermediateJoinOperator,0));
        filter.addSucceedingOperator(new OperatorIDTuple(replaceVar,0));
        intermediateJoinOperator.addSucceedingOperator(new OperatorIDTuple(replaceVari,0));
        replaceVari.addSucceedingOperator(new OperatorIDTuple(replaceVar,0));
        replaceVari.addSucceedingOperator(connection.getOperatorIDTuple());


        if(subjectIsALiteral && !objectIsALiteral){
          final Filter firstFilter = new Filter("(" + subject + " = " + realSubject +")");
          final Filter secondFilter = new Filter("(" + subject + " = " + realSubject +")");

View Full Code Here

0 1 2 3 4 5 6

TOP

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.