Package lupos.engine.operators.tripleoperator

Examples of lupos.engine.operators.tripleoperator.TripleConsumer

146
147
148
149
150
151
152
153
154
155
156
      final Thread codeMapConstructionThread = new Thread() {
        @Override
        public void run() {
            final DBMergeSortedSetUsingTrie rdftermsRepresentations = new DBMergeSortedSetUsingTrie(new SortConfiguration(), String.class);

            final TripleConsumer tc = new TripleConsumer() {

              @Override
              public void consume(final Triple triple) {
                for (final Literal l : triple) {
                  rdftermsRepresentations.add(l.toString());
View Full Code Here
348
349
350
351
352
353
354
355
356
357
358
      final DiskCollection<Triple> triples = new DiskCollection<Triple>(Triple.class);

      try {

        final TripleConsumer tripleConsumer=new TripleConsumer() {

          @Override
          public void consume(final Triple triple) {
            for (final Literal l : triple) {
              searchtree.add(l.toString());
View Full Code Here
580
581
582
583
584
585
586
587
588
589
590
591
592
593
594
595
596
597
598
599
600
601
602
603
604
605
606
607
608
609
610
611
612
613
614
615
616
617
618
                } else {
                  type2 = typeWithoutMultiple;
                }
                readTriplesWithoutMultipleFiles(type2,
                    new FileInputStream(filename),
                    new TripleConsumer() {
                      @Override
                      public void consume(
                          final Triple triple) {
                        try {
                          bbTriples.put(triple);
                        } catch (final InterruptedException e) {
                          log.error(e.getMessage(), e);
                        }
                      }
                    });
              } catch (final Throwable e) {
                log.error(e.getMessage(), e);
              }
            }
            bbTriples.endOfData();
          }
        };
        thread.start();
        Triple t;
        try {
          while ((t = bbTriples.get()) != null) {
            tc.consume(t);
          }
        } catch (final InterruptedException e) {
          log.error(e.getMessage(), e);
        }
      } else {
        final TripleConsumer synchronizedTC = new TripleConsumer() {
          @Override
          public synchronized void consume(final Triple triple) {
            tc.consume(triple);
          }
        };
View Full Code Here
155
156
157
158
159
160
161
162
163
164
165
              if(toAddToRdftermsRepresentations!=null){
                for(final String s: toAddToRdftermsRepresentations){
                  rdftermsRepresentations.add(s);
                }
              }
              final TripleConsumer tc = new TripleConsumer() {

                @Override
                public void consume(final Triple triple) {
                  for (final Literal l : triple) {
                    // rdftermsRepresentations.add(l.
View Full Code Here
460
461
462
463
464
465
466
467
468
469
470
            }
        }
    }

    private void makeLazyLiteral(final int pos, final SortedSet<Triple> dsst_current, final SortedSet<Triple> dsst_next) {
        this.makeLazyLiteral(pos, dsst_current, new TripleConsumer() {

            @Override
            public void consume(final Triple triple) {
                dsst_next.add(triple);
            }
View Full Code Here
520
521
522
523
524
525
526
527
528
529
530
                    new RDF3XIndexConstruction.GenerateIDTriplesUsingStringSearch2(graphURIs, dataFormat, this);
                } else {
                    final SortedSet<Triple> dsst_s;
                    dsst_s = new DBMergeSortedSet<Triple>(new SortConfiguration(), new TripleComparatorCompareStringRepresentationsOrCodeOfLazyLiteral(CollationOrder.SPO), Triple.class);
                    try {
                        CommonCoreQueryEvaluator.readTriples(dataFormat, graphURI.openStream(), new TripleConsumer() {

                            @Override
                            public void consume(final Triple triple) {
                                dsst_s.add(triple);
                            }
View Full Code Here
238
239
240
241
242
243
244
245
246
247
248
          }
        }
        /*
         * Consume each triple of input RDF file
         */
        final TripleConsumer tc = new TripleConsumer() {
          @Override
          public void consume(final Triple triple) {
            try {

              for (int i = 0; i < 3; i++) {
View Full Code Here
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
    } else if (query.isConstructType()) {
      final Model model = qe.execConstruct();
      qe.close();
      final GraphResult gr = new GraphResult();
      TurtleParser.triplesFromModel(model,
          new TripleConsumer() {
            public void consume(final Triple triple) {
              gr.addGraphResultTriple(triple);
            }
          }, TurtleParser.readFileNumber++);
      return gr;
    } else if (query.isDescribeType()) {
      final Model model = qe.execDescribe();
      qe.close();
      final GraphResult gr = new GraphResult();
      TurtleParser.triplesFromModel(model,
          new TripleConsumer() {
            public void consume(final Triple triple) {
              gr.addGraphResultTriple(triple);
            }
          }, TurtleParser.readFileNumber++);
      return gr;
View Full Code Here
51
52
53
54
55
56
57
58
59
60
61
    final GraphResult result = new GraphResult();

    try {
      CommonCoreQueryEvaluator.readTriples(this.formatParameter, inputStream,
          new TripleConsumer(){
            @Override
            public void consume(final Triple triple) {
              result.addGraphResultTriple(triple);
            }
      });
View Full Code Here
121
122
123
124
125
126
127
128
129
130
131
            false);
      }

      CommonCoreQueryEvaluator.readTriples("N3",
          new ByteArrayInputStream(text.getBytes()),
          new TripleConsumer() {
            @Override
            public void consume(final Triple triple) {
              Set<Triple> st = CondensedViewToolBar.this.subjects.get(triple.getSubject());
              if (st == null) {
                st = new HashSet<Triple>();
View Full Code Here
TOP

Related Classes of lupos.engine.operators.tripleoperator.TripleConsumer

  • lupos.datastructures.sort.helper.DataToBoundedBuffer
  • lupos.distributed.p2p.network.impl.EndpointNetwork$DataFileDistribution
  • lupos.endpoint.client.formatreader.TripleFormatReader
  • lupos.engine.evaluators.CommonCoreQueryEvaluator
  • lupos.engine.evaluators.JenaQueryEvaluator
  • lupos.engine.indexconstruction.RDF3XIndexConstruction
  • lupos.engine.indexconstruction.RDF3XIndexConstruction$GenerateIDTriplesUsingStringSearch2
  • lupos.engine.operators.index.adaptedRDF3X.SixIndices
  • lupos.engine.operators.index.Dataset
  • lupos.gui.operatorgraph.visualeditor.dataeditor.DataEditor
    • 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.