Package lupos.datastructures.queryresult

Examples of lupos.datastructures.queryresult.QueryResult

589
590
591
592
593
594
595
596
597
598
599
  public final static NodeInPartitionTree readLuposNodeInPartitionTree(final InputStream in) throws IOException, ClassNotFoundException {
    final byte type = InputHelper.readLuposByte(in);
    switch (type) {
    case 1:
      final Collection<Bindings> coll = PagedCollection.readAndCreateLuposObject(in);
      return new LeafNodeInPartitionTree(new QueryResult(coll));
    default:
    case 2:
      final PagedCollection<NodeInPartitionTree> pcoll = PagedCollection.readAndCreateLuposObject(in);
      return new InnerNodeInPartitionTree(pcoll);
    }
View Full Code Here
85
86
87
88
89
90
91
92
93
94
    }
  }

  public void start(final Type type) {
    qr = null;
    final QueryResult qr;
    gr = null;
    br_list = null;
    this.type = type;
  }
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
   * returned...
   *
   * @return
   */
  public QueryResult getResult() {
    QueryResult result = qr;
    if (result == null)
      result = gr;
    if (result == null && br_list != null)
      result = br_list.get(0);

View Full Code Here
803
804
805
806
807
808
809
810
811
812
813
      this.evaluator.physicalOptimization();

      System.out.println("Evaluate query ...");

      final QueryResult resultQueryEvaluator = this.evaluator.getResult();

      System.out.println("\nQuery Result:");
      System.out.println(resultQueryEvaluator);
      System.out.println("----------------Done.");
View Full Code Here
869
870
871
872
873
874
875
876
877
878
879
880
881
882
883
884
    System.out.println();
    System.out.println(query_succeeding);
    System.out.println();

    // evaluate the queries...
    final QueryResult queryResult_preceding = this
    .queryForSuggestions(query_preceding);
    final QueryResult queryResult_succeeding = this
    .queryForSuggestions(query_succeeding);

    if (queryResult_preceding.isEmpty() && queryResult_succeeding.isEmpty()) {
      JOptionPane.showOptionDialog(this, "No suggestions available!",
          "Error", JOptionPane.DEFAULT_OPTION,
          JOptionPane.ERROR_MESSAGE, null, null, null);

      return;
View Full Code Here
236
237
238
239
240
241
242
243
244
245
246
247
248
249
    return tripleResultAsQueryResult(triplePattern, foundTriples);
  }

  private QueryResult tripleResultAsQueryResult(TriplePattern triplePattern,
      List<Triple> foundTriples) {
    QueryResult result = QueryResult.createInstance();
    if (foundTriples != null)
      for (Triple t : foundTriples) {
        Bindings b = addVariablesToBindings(triplePattern.getItems(), t);
        if (b != null)
          result.add(b);
      }
    return result;
  }
View Full Code Here
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
            LiteralFactory
                .setTypeWithoutInitializing(MapType.LAZYLITERALWITHOUTINITIALPREFIXCODEMAP);
            LiteralFactory
                .setType(MapType.LAZYLITERALWITHOUTINITIALPREFIXCODEMAP);
          }
          final QueryResult queryResult = (EndpointNetwork.this.evaluator instanceof CommonCoreQueryEvaluator) ? ((CommonCoreQueryEvaluator<?>) EndpointNetwork.this.evaluator)
              .getResult(q, true)
              : EndpointNetwork.this.evaluator.getResult(q);
          log.debug(String
              .format("[%s on port %d] Evaluation query in local storage: %s: %d items found",
                  EndpointNetwork.this.evaluator.getClass().getSimpleName(), EndpointNetwork.this.port,
                  q, queryResult.size()));

          /*
           * return result
           */
          if (queryResult != null) {
View Full Code Here
615
616
617
618
619
620
621
622
623
624
625
626
  public List<Triple> get(final String key) {
    /*
     * we will not execute this, if using subgraph-submission
     */
    final List<Triple> lst = new LinkedList<Triple>();
    final QueryResult qr = this.sendDirect(key, "SELECT * WHERE {?s ?p ?o}");
    for (final Iterator<Bindings> it = qr.oneTimeIterator(); it.hasNext();) {
      final Bindings bind = it.next();
      final List<Triple> t = bind.getTriples();
      if (t != null) {
        lst.addAll(t);
      }
View Full Code Here
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
  private final static void evaluateQueryAndPrintOut(
      final QueryEvaluator<Node> evaluator, final String query)
      throws Exception {
    // evaluate query:
    final QueryResult qr = evaluator.getResult(query);

    // use oneTimeIterator() whenever the result need to
    // be iterated only once, otherwise iterator()...
    final Iterator<Bindings> it_query = qr.oneTimeIterator();
    while (it_query.hasNext()) {
      // get next solution of the query...
      final Bindings bindings = it_query.next();
      // print out the bound values of all bindings!
      StringBuilder result=new StringBuilder("{");
View Full Code Here
189
190
191
192
193
194
195
196
197
198
199
200
201
    return b;
  }

  private QueryResult tripleResultAsQueryResult(TriplePattern triplePattern,
      List<Triple> foundTriples) {
    QueryResult result = QueryResult.createInstance();
    for (Triple t : foundTriples) {
      Bindings b = addVariablesToBindings(triplePattern.getItems(), t);
      if (b != null)
        result.add(b);
    }
    return result;
  }
View Full Code Here
TOP

Related Classes of lupos.datastructures.queryresult.QueryResult

  • lupos.datastructures.bindings.Bindings
  • lupos.distributed.operator.AsynchronSubgraphContainer
  • lupos.distributed.operator.SubgraphContainer
  • lupos.distributed.p2p.commandline.StartConsole
  • lupos.distributed.p2p.network.impl.ChordlessLocalStorage
  • lupos.distributed.p2p.network.impl.EndpointNetwork
  • lupos.distributed.p2p.network.impl.TomP2PLocalStorage
  • lupos.distributed.p2p.query.withsubgraph.P2P_SubgraphExecuter
  • lupos.distributed.p2p.storage.StorageWithDistributionStrategy
  • lupos.distributed.query.operator.withouthistogramsubmission.QueryClientIndexScan
    • 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.