Package lupos.engine.operators.messages

Examples of lupos.engine.operators.messages.StartOfEvaluationMessage

766
767
768
769
770
771
772
773
774
775
776
  @Override
  public long evaluateQuery() throws Exception {
    final CountResult cr = new CountResult();
    this.result.addApplication(cr);
    final Date a = new Date();
    this.rootNode.sendMessage(new StartOfEvaluationMessage());
    for(final URILiteral in: this.defaultGraphs) {
      CommonCoreQueryEvaluator.readTriples(this.type, in.openStream(), (TripleConsumer) this.rootNode);
    }
    this.rootNode.sendMessage(new EndOfEvaluationMessage());
    return ((new Date()).getTime() - a.getTime());
View Full Code Here
799
800
801
802
803
804
805
806
807
808
809
  @Override
  public long evaluateQueryDebugSteps(final DebugStep debugstep, final Application application)
  throws Exception {
    this.result.addApplication(application);
    final Date a = new Date();
    this.rootNode.sendMessageDebug(new StartOfEvaluationMessage(), debugstep);
    for(final URILiteral in: this.defaultGraphs) {
      CommonCoreQueryEvaluator.readTriples(this.type, in.openStream(), (TripleConsumer) this.rootNode);
    }
    this.rootNode.sendMessageDebug(new EndOfEvaluationMessage(), debugstep);
    return ((new Date()).getTime() - a.getTime());
View Full Code Here
649
650
651
652
653
654
655
656
657
658
659
        this.setBindingsVariablesBasedOnOperatorgraph();
      }
    }

    final Date a = new Date();
    this.root.sendMessage(new StartOfEvaluationMessage());
    this.root.startProcessing();
    this.root.sendMessage(new EndOfEvaluationMessage());
    final long time = ((new Date()).getTime() - a.getTime());

//    System.out.println("Number of results:" + cr.getNumberResults());
View Full Code Here
709
710
711
712
713
714
715
716
717
718
719
        this.setBindingsVariablesBasedOnOperatorgraph();
      }
    }

    final Date a = new Date();
    this.root.sendMessageDebug(new StartOfEvaluationMessage(),
        debugstep);
    this.root.startProcessingDebug(debugstep);
    this.root.sendMessageDebug(new EndOfEvaluationMessage(),
        debugstep);
    final long time = ((new Date()).getTime() - a.getTime());
View Full Code Here
147
148
149
150
151
152
153
154
155
156
157
   *
   * @param stream
   *            the root operator of the stream query
   */
  public void generateStream(final Stream stream) {
    stream.sendMessage(new StartOfEvaluationMessage());
    try {
      final Literal s = LiteralFactory.createURILiteral("<s>");
      final Literal p = LiteralFactory.createURILiteral("<p>");
      int i = 0;
      while (this.loop) {
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
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
176
177
178
179
180
181
182
183
184
185
186
      evaluator.logicalOptimization();
      evaluator.physicalOptimization();
      if (evaluator.getRootNode() instanceof Stream) {
        Stream stream = (Stream) evaluator.getRootNode();
        stream.addNotifyStreamResult(notifyStreamResult);
        stream.sendMessage(new StartOfEvaluationMessage());
        return stream;
      }
     
    } catch (Exception e) {
      System.err.println(e);
View Full Code Here
345
346
347
348
349
350
351
352
353
354
355
      evaluator.logicalOptimization();
      evaluator.physicalOptimization();
      if (evaluator.getRootNode() instanceof Stream) {
        Stream stream = (Stream) evaluator.getRootNode();
        stream.addNotifyStreamResult(notifyStreamResult);
        stream.sendMessage(new StartOfEvaluationMessage());
        return stream;
      }
     
    } catch (Exception e) {
      System.err.println(e);
View Full Code Here
TOP

Related Classes of lupos.engine.operators.messages.StartOfEvaluationMessage

  • lupos.distributed.storage.util.LocalExecutor
  • lupos.engine.evaluators.BasicIndexQueryEvaluator
  • lupos.engine.evaluators.StreamQueryEvaluator
  • lupos.event.broker.centralized.Broker
  • lupos.event.broker.distributed.SubBroker
  • lupos.test.TestStream
    • Copyright © 2018 www.massapicom. 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.