Examples of addSucceedingOperator()

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

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

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

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

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

Examples of lupos.engine.operators.singleinput.federated.FederatedQueryTrivialApproach.addSucceedingOperator()

64
65
66
67
68
69
70
71
72
73
      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.filter.Filter.addSucceedingOperator()

617
618
619
620
621
622
623
624
625
626
627
      final Item b, final Item c, final String filter,
      final TriplePattern tp2) {
    try {
      final Filter f = new Filter(filter);
      final Generate g = new Generate(tp, a, b, c);
      f.addSucceedingOperator(new OperatorIDTuple(g, 0));
      tp2.setSucceedingOperator(new OperatorIDTuple(f, 0));
      final Collection<TriplePattern> ctp = new LinkedList<TriplePattern>();
      ctp.add(tp2);
      ic.addSucceedingOperator(new OperatorIDTuple(ic.newIndexScan(
          new OperatorIDTuple(f, 0), ctp, null), 0));
View Full Code Here

Examples of lupos.engine.operators.singleinput.filter.Filter.addSucceedingOperator()

640
641
642
643
644
645
646
647
648
649
650
      final Filter f1 = new Filter(filter1);
      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);
View Full Code Here

Examples of lupos.engine.operators.singleinput.filter.Filter.addSucceedingOperator()

666
667
668
669
670
671
672
673
674
675
676
      final TriplePattern tp1, final TriplePattern tp2) {
    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);
View Full Code Here

Examples of lupos.engine.operators.singleinput.generate.Generate.addSucceedingOperator()

561
562
563
564
565
566
567
568
569
570
571
      final Item[] generateItems = generate.getValueOrVariable();
      for(final BasicOperator tpOrIndexScan: new LinkedList<BasicOperator>(toBeConnectedTo)){
        if(tpOrIndexScan instanceof TriplePattern){
          final TriplePattern tpi = (TriplePattern) tpOrIndexScan;
          if(BasicIndexRuleEvaluator.isMatching(tpi, generateItems)){
            generate.addSucceedingOperator(tpOrIndexScan);
          }
        } else {
          final BasicIndexScan bi = (BasicIndexScan) tpOrIndexScan;
          if(bi.getTriplePattern()!=null && bi.getTriplePattern().size()>0){
            final LinkedList<TriplePattern> matchingTPs = new LinkedList<TriplePattern>();
View Full Code Here

Examples of lupos.engine.operators.singleinput.modifiers.distinct.Distinct.addSucceedingOperator()

62
63
64
65
66
67
68
69
70
71
72
      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.modifiers.distinct.InMemoryDistinct.addSucceedingOperator()

520
521
522
523
524
525
526
527
528
529
530
        startingOperator.addSucceedingOperator(new OperatorIDTuple(filter,0));
        startingOperator.addSucceedingOperator(connection.getOperatorIDTuple());
        final Join intermediateJoinOperator = new Join();
        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());
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.