Package lupos.engine.operators.tripleoperator

Examples of lupos.engine.operators.tripleoperator.TripleConsumer

232
233
234
235
236
237
238
239
240
241
242
      final LinkedHashMap<Item, DataRDFTerm> rdfHash = new LinkedHashMap<Item, DataRDFTerm>();
      final LinkedHashSet<Operator> rdfTermToJoin = new LinkedHashSet<Operator>();

      try {
        CommonCoreQueryEvaluator.readTriples("Turtle", rdfURL.openStream(),
            new TripleConsumer() {
          public void consume(final Triple triple) {
            DataRDFTerm rdfTermSubject = rdfHash.get(triple
                .getPos(0));

            if (rdfTermSubject == null) {
View Full Code Here
471
472
473
474
475
476
477
478
479
480
481
              + ">", false);
        }
      }

      // now really get the triples!
      CommonCoreQueryEvaluator.readTriples("N3", rdfURL.openStream(), new TripleConsumer() {
        public void consume(final Triple triple) {
          DataRDFTerm rdfTermSubject = rdfHash.get(triple.getPos(0));

          if(rdfTermSubject == null) {
            rdfTermSubject = new DataRDFTerm(prefix, triple.getPos(0));
View Full Code Here
70
71
72
73
74
75
76
77
78
79
80
   * @throws Exception in case of any failure
   */
  private static void rdfTerms(final InputStream dataFiles, final String format, final BoundedBuffer<String> buffer) throws Exception{
    // now parse the data...
    CommonCoreQueryEvaluator.readTriples(format, dataFiles,
        new TripleConsumer(){
          @Override
          public void consume(Triple triple) {
            for(Literal literal: triple){
              try {
                buffer.put(literal.originalString());
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.