Package lupos.engine.operators.index

Examples of lupos.engine.operators.index.Root.sendMessage()

149
150
151
152
153
154
155
156
157
158
159
    // some initializations
    root.deleteParents();
    root.setParents();
    root.detectCycles();
    root.sendMessage(new BoundVariablesMessage());

    Class<? extends Bindings> instanceClass = null;
    if (Bindings.instanceClass == BindingsArrayVarMinMax.class
        || Bindings.instanceClass == BindingsArrayPresortingNumbers.class) {
      // is BindingsArrayVarMinMax or BindingsArrayPresortingNumbers
View Full Code Here
185
186
187
188
189
190
191
192
193
194
195
        Bindings.instanceClass = BindingsArray.class;
      }
    }

    final BindingsFactory bindingsFactory= BindingsFactory.createBindingsFactory(CommonCoreQueryEvaluator.getAllVariablesOfQuery(root));
    root.sendMessage(new BindingsFactoryMessage(bindingsFactory));

    // evaluate subgraph!
    root.sendMessage(new StartOfEvaluationMessage());
    root.startProcessing();
    root.sendMessage(new EndOfEvaluationMessage());
View Full Code Here
188
189
190
191
192
193
194
195
196
197
198
    final BindingsFactory bindingsFactory= BindingsFactory.createBindingsFactory(CommonCoreQueryEvaluator.getAllVariablesOfQuery(root));
    root.sendMessage(new BindingsFactoryMessage(bindingsFactory));

    // evaluate subgraph!
    root.sendMessage(new StartOfEvaluationMessage());
    root.startProcessing();
    root.sendMessage(new EndOfEvaluationMessage());

    if (instanceClass != null) {
      Bindings.instanceClass = instanceClass;
View Full Code Here
190
191
192
193
194
195
196
197
198
199
200
    root.sendMessage(new BindingsFactoryMessage(bindingsFactory));

    // evaluate subgraph!
    root.sendMessage(new StartOfEvaluationMessage());
    root.startProcessing();
    root.sendMessage(new EndOfEvaluationMessage());

    if (instanceClass != null) {
      Bindings.instanceClass = instanceClass;
    }
    return new Tuple<QueryResult, Set<Variable>>(collectResult.getResult(), new HashSet<Variable>(LocalExecutor.getVariables(root)));
View Full Code Here
399
400
401
402
403
404
405
406
407
408
409
    // some initializations
    root.deleteParents();
    root.setParents();
    root.detectCycles();
    root.sendMessage(new BoundVariablesMessage());


    Class<? extends Bindings> instanceClass = null;
    if (Bindings.instanceClass == BindingsArrayVarMinMax.class
        || Bindings.instanceClass == BindingsArrayPresortingNumbers.class) {
View Full Code Here
446
447
448
449
450
451
452
453
454
455
456
    final AfterPhysicalOptimizationDistributedRulePackage refie = new AfterPhysicalOptimizationDistributedRulePackage();
    refie.applyRules(root);

    // evaluate subgraph!
    final BindingsFactory bindingsFactory= BindingsFactory.createBindingsFactory(CommonCoreQueryEvaluator.getAllVariablesOfQuery(root));
    root.sendMessage(new BindingsFactoryMessage(bindingsFactory));

    root.sendMessage(new StartOfEvaluationMessage());
    root.startProcessing();
    root.sendMessage(new EndOfEvaluationMessage());
View Full Code Here
448
449
450
451
452
453
454
455
456
457
458
    // evaluate subgraph!
    final BindingsFactory bindingsFactory= BindingsFactory.createBindingsFactory(CommonCoreQueryEvaluator.getAllVariablesOfQuery(root));
    root.sendMessage(new BindingsFactoryMessage(bindingsFactory));

    root.sendMessage(new StartOfEvaluationMessage());
    root.startProcessing();
    root.sendMessage(new EndOfEvaluationMessage());

    if (instanceClass != null) {
      Bindings.instanceClass = instanceClass;
View Full Code Here
450
451
452
453
454
455
456
457
458
459
460
    final BindingsFactory bindingsFactory= BindingsFactory.createBindingsFactory(CommonCoreQueryEvaluator.getAllVariablesOfQuery(root));
    root.sendMessage(new BindingsFactoryMessage(bindingsFactory));

    root.sendMessage(new StartOfEvaluationMessage());
    root.startProcessing();
    root.sendMessage(new EndOfEvaluationMessage());

    if (instanceClass != null) {
      Bindings.instanceClass = instanceClass;
    }
    //Result is back ..
View Full Code Here
1433
1434
1435
1436
1437
1438
1439
1440
1441
1442
1443
          this.visit((ASTGroupConstraint) n.jjtGetChild(0), connection, graphConstraint);

          collectionClone.deleteParents();
          collectionClone.setParents();
          collectionClone.detectCycles();
          collectionClone.sendMessage(new BoundVariablesMessage());
          final CorrectOperatorgraphRulePackage recog = new CorrectOperatorgraphRulePackage();
          recog.applyRules(collectionClone);

          filter.getCollectionForExistNodes().put((SimpleNode) n, collectionClone);
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.