Return-Path: X-Original-To: archive-asf-public-internal@cust-asf2.ponee.io Delivered-To: archive-asf-public-internal@cust-asf2.ponee.io Received: from cust-asf.ponee.io (cust-asf.ponee.io [163.172.22.183]) by cust-asf2.ponee.io (Postfix) with ESMTP id 57051200BC1 for ; Wed, 16 Nov 2016 11:57:45 +0100 (CET) Received: by cust-asf.ponee.io (Postfix) id 55784160B1B; Wed, 16 Nov 2016 10:57:45 +0000 (UTC) Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by cust-asf.ponee.io (Postfix) with SMTP id D8A06160B13 for ; Wed, 16 Nov 2016 11:57:42 +0100 (CET) Received: (qmail 17550 invoked by uid 500); 16 Nov 2016 10:57:42 -0000 Mailing-List: contact commits-help@commonsrdf.incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@commonsrdf.incubator.apache.org Delivered-To: mailing list commits@commonsrdf.incubator.apache.org Received: (qmail 17541 invoked by uid 99); 16 Nov 2016 10:57:42 -0000 Received: from pnap-us-west-generic-nat.apache.org (HELO spamd1-us-west.apache.org) (209.188.14.142) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 16 Nov 2016 10:57:42 +0000 Received: from localhost (localhost [127.0.0.1]) by spamd1-us-west.apache.org (ASF Mail Server at spamd1-us-west.apache.org) with ESMTP id 84FFAC0BF8 for ; Wed, 16 Nov 2016 10:57:41 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: 0.001 X-Spam-Level: X-Spam-Status: No, score=0.001 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, KAM_LINEPADDING=1.2, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-us.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id lKHAvElKMdB2 for ; Wed, 16 Nov 2016 10:57:35 +0000 (UTC) Received: from mailrelay1-us-west.apache.org (mailrelay1-us-west.apache.org [209.188.14.139]) by mx1-lw-us.apache.org (ASF Mail Server at mx1-lw-us.apache.org) with ESMTP id 9B9165FCA7 for ; Wed, 16 Nov 2016 10:57:34 +0000 (UTC) Received: from svn01-us-west.apache.org (svn.apache.org [10.41.0.6]) by mailrelay1-us-west.apache.org (ASF Mail Server at mailrelay1-us-west.apache.org) with ESMTP id 64DBFE866E for ; Wed, 16 Nov 2016 10:57:32 +0000 (UTC) Received: from svn01-us-west.apache.org (localhost [127.0.0.1]) by svn01-us-west.apache.org (ASF Mail Server at svn01-us-west.apache.org) with ESMTP id 144B33A3A48 for ; Wed, 16 Nov 2016 10:57:32 +0000 (UTC) Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit Subject: svn commit: r1001192 [10/30] - in /websites/production/commonsrdf/content: ./ apidocs/ apidocs/org/apache/commons/rdf/api/ apidocs/org/apache/commons/rdf/experimental/ apidocs/org/apache/commons/rdf/simple/ apidocs/org/apache/commons/rdf/simple/class-u... Date: Wed, 16 Nov 2016 10:57:30 -0000 To: commits@commonsrdf.incubator.apache.org From: stain@apache.org X-Mailer: svnmailer-1.0.9 Message-Id: <20161116105732.144B33A3A48@svn01-us-west.apache.org> archived-at: Wed, 16 Nov 2016 10:57:45 -0000 Added: websites/production/commonsrdf/content/apidocs/src-html/org/apache/commons/rdf/simple/experimental/AbstractRDFParser.html ============================================================================== --- websites/production/commonsrdf/content/apidocs/src-html/org/apache/commons/rdf/simple/experimental/AbstractRDFParser.html (added) +++ websites/production/commonsrdf/content/apidocs/src-html/org/apache/commons/rdf/simple/experimental/AbstractRDFParser.html Wed Nov 16 10:57:28 2016 @@ -0,0 +1,641 @@ + + + +Source code + + + +
+
001/**
+002 * Licensed to the Apache Software Foundation (ASF) under one
+003 * or more contributor license agreements. See the NOTICE file
+004 * distributed with this work for additional information
+005 * regarding copyright ownership. The ASF licenses this file
+006 * to you under the Apache License, Version 2.0 (the
+007 * "License"); you may not use this file except in compliance
+008 * with the License.  You may obtain a copy of the License at
+009 *
+010 *     http://www.apache.org/licenses/LICENSE-2.0
+011 *
+012 * Unless required by applicable law or agreed to in writing, software
+013 * distributed under the License is distributed on an "AS IS" BASIS,
+014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+015 * See the License for the specific language governing permissions and
+016 * limitations under the License.
+017 */
+018package org.apache.commons.rdf.simple.experimental;
+019
+020import java.io.IOException;
+021import java.io.InputStream;
+022import java.net.URI;
+023import java.nio.file.Files;
+024import java.nio.file.Path;
+025import java.util.Optional;
+026import java.util.concurrent.ExecutorService;
+027import java.util.concurrent.Executors;
+028import java.util.concurrent.Future;
+029import java.util.function.Consumer;
+030
+031import org.apache.commons.rdf.api.Dataset;
+032import org.apache.commons.rdf.api.Graph;
+033import org.apache.commons.rdf.api.IRI;
+034import org.apache.commons.rdf.api.Quad;
+035import org.apache.commons.rdf.api.RDFSyntax;
+036import org.apache.commons.rdf.api.RDF;
+037import org.apache.commons.rdf.experimental.RDFParser;
+038import org.apache.commons.rdf.simple.SimpleRDF;
+039
+040/**
+041 * Abstract RDFParser
+042 * <p>
+043 * This abstract class keeps the properties in protected fields like
+044 * {@link #sourceFile} using {@link Optional}. Some basic checking like
+045 * {@link #checkIsAbsolute(IRI)} is performed.
+046 * <p>
+047 * This class and its subclasses are {@link Cloneable}, immutable and
+048 * (therefore) thread-safe - each call to option methods like
+049 * {@link #contentType(String)} or {@link #source(IRI)} will return a cloned,
+050 * mutated copy.
+051 * <p>
+052 * By default, parsing is done by the abstract method
+053 * {@link #parseSynchronusly()} - which is executed in a cloned snapshot - hence
+054 * multiple {@link #parse()} calls are thread-safe. The default {@link #parse()}
+055 * uses a thread pool in {@link #threadGroup} - but implementations can override
+056 * {@link #parse()} (e.g. because it has its own threading model or use
+057 * asynchronous remote execution).
+058 */
+059public abstract class AbstractRDFParser<T extends AbstractRDFParser<T>> implements RDFParser, Cloneable {
+060
+061    public static final ThreadGroup threadGroup = new ThreadGroup("Commons RDF parsers");
+062    private static final ExecutorService threadpool = Executors.newCachedThreadPool(r -> new Thread(threadGroup, r));
+063
+064    // Basically only used for creating IRIs
+065    private static RDF internalRdfTermFactory = new SimpleRDF();
+066
+067    /**
+068     * Get the set {@link RDF}, if any.
+069     * 
+070     * @return The {@link RDF} to use, or {@link Optional#empty()} if it has not
+071     *         been set
+072     */
+073    public Optional<RDF> getRdfTermFactory() {
+074        return rdfTermFactory;
+075    }
+076
+077    /**
+078     * Get the set content-type {@link RDFSyntax}, if any.
+079     * <p>
+080     * If this is {@link Optional#isPresent()}, then {@link #getContentType()}
+081     * contains the value of {@link RDFSyntax#mediaType}.
+082     * 
+083     * @return The {@link RDFSyntax} of the content type, or
+084     *         {@link Optional#empty()} if it has not been set
+085     */
+086    public Optional<RDFSyntax> getContentTypeSyntax() {
+087        return contentTypeSyntax;
+088    }
+089
+090    /**
+091     * Get the set content-type String, if any.
+092     * <p>
+093     * If this is {@link Optional#isPresent()} and is recognized by
+094     * {@link RDFSyntax#byMediaType(String)}, then the corresponding
+095     * {@link RDFSyntax} is set on {@link #getContentType()}, otherwise that is
+096     * {@link Optional#empty()}.
+097     * 
+098     * @return The Content-Type IANA media type, e.g. <code>text/turtle</code>,
+099     *         or {@link Optional#empty()} if it has not been set
+100     */
+101    public final Optional<String> getContentType() {
+102        return contentType;
+103    }
+104
+105    /**
+106     * Get the target to consume parsed Quads.
+107     * <p>
+108     * From the call to {@link #parseSynchronusly()}, this will be a
+109     * non-<code>null</code> value (as a target is a required setting).
+110     * 
+111     * @return The target consumer of {@link Quad}s, or <code>null</code> if it
+112     *         has not yet been set.
+113     * 
+114     */
+115    public Consumer<Quad> getTarget() {
+116        return target;
+117    }
+118
+119    /**
+120     * Get the target dataset as set by {@link #target(Dataset)}.
+121     * <p>
+122     * The return value is {@link Optional#isPresent()} if and only if
+123     * {@link #target(Dataset)} has been set, meaning that the implementation
+124     * may choose to append parsed quads to the {@link Dataset} directly instead
+125     * of relying on the generated {@link #getTarget()} consumer.
+126     * <p>
+127     * If this value is present, then {@link #getTargetGraph()} MUST be
+128     * {@link Optional#empty()}.
+129     * 
+130     * @return The target Dataset, or {@link Optional#empty()} if another kind
+131     *         of target has been set.
+132     */
+133    public Optional<Dataset> getTargetDataset() {
+134        return targetDataset;
+135    }
+136
+137    /**
+138     * Get the target graph as set by {@link #target(Graph)}.
+139     * <p>
+140     * The return value is {@link Optional#isPresent()} if and only if
+141     * {@link #target(Graph)} has been set, meaning that the implementation may
+142     * choose to append parsed triples to the {@link Graph} directly instead of
+143     * relying on the generated {@link #getTarget()} consumer.
+144     * <p>
+145     * If this value is present, then {@link #getTargetDataset()} MUST be
+146     * {@link Optional#empty()}.
+147     * 
+148     * @return The target Graph, or {@link Optional#empty()} if another kind of
+149     *         target has been set.
+150     */
+151    public Optional<Graph> getTargetGraph() {
+152        return targetGraph;
+153    }
+154
+155    /**
+156     * Get the set base {@link IRI}, if present.
+157     * 
+158     * @return The base {@link IRI}, or {@link Optional#empty()} if it has not
+159     *         been set
+160     */
+161    public Optional<IRI> getBase() {
+162        return base;
+163    }
+164
+165    /**
+166     * Get the set source {@link InputStream}.
+167     * <p>
+168     * If this is {@link Optional#isPresent()}, then {@link #getSourceFile()}
+169     * and {@link #getSourceIri()} are {@link Optional#empty()}.
+170     * 
+171     * @return The source {@link InputStream}, or {@link Optional#empty()} if it
+172     *         has not been set
+173     */
+174    public Optional<InputStream> getSourceInputStream() {
+175        return sourceInputStream;
+176    }
+177
+178    /**
+179     * Get the set source {@link Path}.
+180     * <p>
+181     * If this is {@link Optional#isPresent()}, then
+182     * {@link #getSourceInputStream()} and {@link #getSourceIri()} are
+183     * {@link Optional#empty()}.
+184     *
+185     * @return The source {@link Path}, or {@link Optional#empty()} if it has
+186     *         not been set
+187     */
+188    public Optional<Path> getSourceFile() {
+189        return sourceFile;
+190    }
+191
+192    /**
+193     * Get the set source {@link Path}.
+194     * <p>
+195     * If this is {@link Optional#isPresent()}, then
+196     * {@link #getSourceInputStream()} and {@link #getSourceInputStream()} are
+197     * {@link Optional#empty()}.
+198     * 
+199     * @return The source {@link IRI}, or {@link Optional#empty()} if it has not
+200     *         been set
+201     */
+202    public Optional<IRI> getSourceIri() {
+203        return sourceIri;
+204    }
+205
+206    private Optional<RDF> rdfTermFactory = Optional.empty();
+207    private Optional<RDFSyntax> contentTypeSyntax = Optional.empty();
+208    private Optional<String> contentType = Optional.empty();
+209    private Optional<IRI> base = Optional.empty();
+210    private Optional<InputStream> sourceInputStream = Optional.empty();
+211    private Optional<Path> sourceFile = Optional.empty();
+212    private Optional<IRI> sourceIri = Optional.empty();
+213    private Consumer<Quad> target;
+214    private Optional<Dataset> targetDataset;
+215    private Optional<Graph> targetGraph;
+216
+217    @SuppressWarnings("unchecked")
+218    @Override
+219    public T clone() {
+220        try {
+221            return (T) super.clone();
+222        } catch (CloneNotSupportedException e) {
+223            throw new RuntimeException(e);
+224        }
+225    }
+226
+227    @SuppressWarnings("unchecked")
+228    protected T asT() {
+229        return (T) this;
+230    }
+231
+232    @Override
+233    public T rdfTermFactory(RDF rdfTermFactory) {
+234        AbstractRDFParser<T> c = clone();
+235        c.rdfTermFactory = Optional.ofNullable(rdfTermFactory);
+236        return c.asT();
+237    }
+238
+239    @Override
+240    public T contentType(RDFSyntax rdfSyntax) throws IllegalArgumentException {
+241        AbstractRDFParser<T> c = clone();
+242        c.contentTypeSyntax = Optional.ofNullable(rdfSyntax);
+243        c.contentType = c.contentTypeSyntax.map(syntax -> syntax.mediaType);
+244        return c.asT();
+245    }
+246
+247    @Override
+248    public T contentType(String contentType) throws IllegalArgumentException {
+249        AbstractRDFParser<T> c = clone();
+250        c.contentType = Optional.ofNullable(contentType);
+251        c.contentTypeSyntax = c.contentType.flatMap(RDFSyntax::byMediaType);
+252        return c.asT();
+253    }
+254
+255    @Override
+256    public T base(IRI base) {
+257        AbstractRDFParser<T> c = clone();
+258        c.base = Optional.ofNullable(base);
+259        c.base.ifPresent(i -> checkIsAbsolute(i));
+260        return c.asT();
+261    }
+262
+263    @Override
+264    public T base(String base) throws IllegalArgumentException {
+265        return base(internalRdfTermFactory.createIRI(base));
+266    }
+267
+268    @Override
+269    public T source(InputStream inputStream) {
+270        AbstractRDFParser<T> c = clone();
+271        c.resetSource();
+272        c.sourceInputStream = Optional.ofNullable(inputStream);
+273        return c.asT();
+274    }
+275
+276    @Override
+277    public T source(Path file) {
+278        AbstractRDFParser<T> c = clone();
+279        c.resetSource();
+280        c.sourceFile = Optional.ofNullable(file);
+281        return c.asT();
+282    }
+283
+284    @Override
+285    public T source(IRI iri) {
+286        AbstractRDFParser<T> c = clone();
+287        c.resetSource();
+288        c.sourceIri = Optional.ofNullable(iri);
+289        c.sourceIri.ifPresent(i -> checkIsAbsolute(i));
+290        return c.asT();
+291    }
+292
+293    @Override
+294    public T source(String iri) throws IllegalArgumentException {
+295        AbstractRDFParser<T> c = clone();
+296        c.resetSource();
+297        c.sourceIri = Optional.ofNullable(iri).map(internalRdfTermFactory::createIRI);
+298        c.sourceIri.ifPresent(i -> checkIsAbsolute(i));
+299        return source(internalRdfTermFactory.createIRI(iri));
+300    }
+301
+302    /**
+303     * Check if an iri is absolute.
+304     * <p>
+305     * Used by {@link #source(String)} and {@link #base(String)}.
+306     * 
+307     * @param iri
+308     *            IRI to check
+309     * @throws IllegalArgumentException
+310     *             If the IRI is not absolute
+311     */
+312    protected void checkIsAbsolute(IRI iri) throws IllegalArgumentException {
+313        if (!URI.create(iri.getIRIString()).isAbsolute()) {
+314            throw new IllegalArgumentException("IRI is not absolute: " + iri);
+315        }
+316    }
+317
+318    /**
+319     * Check that one and only one source is present and valid.
+320     * <p>
+321     * Used by {@link #parse()}.
+322     * <p>
+323     * Subclasses might override this method, e.g. to support other source
+324     * combinations, or to check if the sourceIri is resolvable.
+325     * 
+326     * @throws IOException
+327     *             If a source file can't be read
+328     */
+329    protected void checkSource() throws IOException {
+330        if (!sourceFile.isPresent() && !sourceInputStream.isPresent() && !sourceIri.isPresent()) {
+331            throw new IllegalStateException("No source has been set");
+332        }
+333        if (sourceIri.isPresent() && sourceInputStream.isPresent()) {
+334            throw new IllegalStateException("Both sourceIri and sourceInputStream have been set");
+335        }
+336        if (sourceIri.isPresent() && sourceFile.isPresent()) {
+337            throw new IllegalStateException("Both sourceIri and sourceFile have been set");
+338        }
+339        if (sourceInputStream.isPresent() && sourceFile.isPresent()) {
+340            throw new IllegalStateException("Both sourceInputStream and sourceFile have been set");
+341        }
+342        if (sourceFile.isPresent() && !sourceFile.filter(Files::isReadable).isPresent()) {
+343            throw new IOException("Can't read file: " + sourceFile);
+344        }
+345    }
+346
+347    /**
+348     * Check if base is required.
+349     * 
+350     * @throws IllegalStateException
+351     *             if base is required, but not set.
+352     */
+353    protected void checkBaseRequired() throws IllegalStateException {
+354        if (!base.isPresent() && sourceInputStream.isPresent()
+355                && !contentTypeSyntax.filter(t -> t == RDFSyntax.NQUADS || t == RDFSyntax.NTRIPLES).isPresent()) {
+356            throw new IllegalStateException("base iri required for inputstream source");
+357        }
+358    }
+359
+360    /**
+361     * Reset all source* fields to Optional.empty()
+362     * <p>
+363     * Subclasses should override this and call <code>super.resetSource()</code>
+364     * if they need to reset any additional source* fields.
+365     * 
+366     */
+367    protected void resetSource() {
+368        sourceInputStream = Optional.empty();
+369        sourceIri = Optional.empty();
+370        sourceFile = Optional.empty();
+371    }
+372
+373    /**
+374     * Reset all optional target* fields to {@link Optional#empty()}.
+375     * <p>
+376     * Note that the consumer set for {@link #getTarget()} is
+377     * <strong>note</strong> reset.
+378     * <p>
+379     * Subclasses should override this and call <code>super.resetTarget()</code>
+380     * if they need to reset any additional target* fields.
+381     * 
+382     */
+383    protected void resetTarget() {
+384        targetDataset = Optional.empty();
+385        targetGraph = Optional.empty();
+386    }
+387
+388    /**
+389     * Parse {@link #sourceInputStream}, {@link #sourceFile} or
+390     * {@link #sourceIri}.
+391     * <p>
+392     * One of the source fields MUST be present, as checked by
+393     * {@link #checkSource()}.
+394     * <p>
+395     * {@link #checkBaseRequired()} is called to verify if {@link #getBase()} is
+396     * required.
+397     * 
+398     * @throws IOException
+399     *             If the source could not be read
+400     * @throws RDFParseException
+401     *             If the source could not be parsed (e.g. a .ttl file was not
+402     *             valid Turtle)
+403     */
+404    protected abstract void parseSynchronusly() throws IOException, RDFParseException;
+405
+406    /**
+407     * Prepare a clone of this RDFParser which have been checked and completed.
+408     * <p>
+409     * The returned clone will always have {@link #getTarget()} and
+410     * {@link #getRdfTermFactory()} present.
+411     * <p>
+412     * If the {@link #getSourceFile()} is present, but the {@link #getBase()} is
+413     * not present, the base will be set to the <code>file:///</code> IRI for
+414     * the Path's real path (e.g. resolving any symbolic links).
+415     * 
+416     * @return A completed and checked clone of this RDFParser
+417     * @throws IOException
+418     *             If the source was not accessible (e.g. a file was not found)
+419     * @throws IllegalStateException
+420     *             If the parser was not in a compatible setting (e.g.
+421     *             contentType was an invalid string)
+422     */
+423    protected T prepareForParsing() throws IOException, IllegalStateException {
+424        checkSource();
+425        checkBaseRequired();
+426        checkContentType();
+427        checkTarget();
+428
+429        // We'll make a clone of our current state which will be passed to
+430        // parseSynchronously()
+431        AbstractRDFParser<T> c = clone();
+432
+433        // Use a fresh SimpleRDF for each parse
+434        if (!c.rdfTermFactory.isPresent()) {
+435            c.rdfTermFactory = Optional.of(createRDFTermFactory());
+436        }
+437        // sourceFile, but no base? Let's follow any symlinks and use
+438        // the file:/// URI
+439        if (c.sourceFile.isPresent() && !c.base.isPresent()) {
+440            URI baseUri = c.sourceFile.get().toRealPath().toUri();
+441            c.base = Optional.of(internalRdfTermFactory.createIRI(baseUri.toString()));
+442        }
+443
+444        return c.asT();
+445    }
+446
+447    /**
+448     * Subclasses can override this method to check the target is valid.
+449     * <p>
+450     * The default implementation throws an IllegalStateException if the target
+451     * has not been set.
+452     */
+453    protected void checkTarget() {
+454        if (target == null) {
+455            throw new IllegalStateException("target has not been set");
+456        }
+457        if (targetGraph.isPresent() && targetDataset.isPresent()) {
+458            // This should not happen as each target(..) method resets the
+459            // optionals
+460            throw new IllegalStateException("targetGraph and targetDataset can't both be set");
+461        }
+462    }
+463
+464    /**
+465     * Subclasses can override this method to check compatibility with the
+466     * contentType setting.
+467     * 
+468     * @throws IllegalStateException
+469     *             if the {@link #getContentType()} or
+470     *             {@link #getContentTypeSyntax()} is not compatible or invalid
+471     */
+472    protected void checkContentType() throws IllegalStateException {
+473    }
+474
+475    /**
+476     * Guess RDFSyntax from a local file's extension.
+477     * <p>
+478     * This method can be used by subclasses if {@link #getContentType()} is not
+479     * present and {@link #getSourceFile()} is set.
+480     * 
+481     * @param path
+482     *            Path which extension should be checked
+483     * @return The {@link RDFSyntax} which has a matching
+484     *         {@link RDFSyntax#fileExtension}, otherwise
+485     *         {@link Optional#empty()}.
+486     */
+487    protected static Optional<RDFSyntax> guessRDFSyntax(Path path) {
+488        return fileExtension(path).flatMap(RDFSyntax::byFileExtension);
+489    }
+490
+491    /**
+492     * Return the file extension of a Path - if any.
+493     * <p>
+494     * The returned file extension includes the leading <code>.</code>
+495     * <p>
+496     * Note that this only returns the last extension, e.g. the file extension
+497     * for <code>archive.tar.gz</code> would be <code>.gz</code>
+498     * 
+499     * @param path
+500     *            Path which filename might contain an extension
+501     * @return File extension (including the leading <code>.</code>, or
+502     *         {@link Optional#empty()} if the path has no extension
+503     */
+504    private static Optional<String> fileExtension(Path path) {
+505        Path fileName = path.getFileName();
+506        if (fileName == null) {
+507            return Optional.empty();
+508        }
+509        String filenameStr = fileName.toString();
+510        int last = filenameStr.lastIndexOf(".");
+511        if (last > -1) {
+512            return Optional.of(filenameStr.substring(last));
+513        }
+514        return Optional.empty();
+515    }
+516
+517    /**
+518     * Create a new {@link RDF} for a parse session.
+519     * <p>
+520     * This is called by {@link #parse()} to set {@link #rdfTermFactory(RDF)} if
+521     * it is {@link Optional#empty()}.
+522     * <p>
+523     * As parsed blank nodes might be made with
+524     * {@link RDF#createBlankNode(String)}, each call to this method SHOULD
+525     * return a new RDF instance.
+526     * 
+527     * @return A new {@link RDF}
+528     */
+529    protected RDF createRDFTermFactory() {
+530        return new SimpleRDF();
+531    }
+532
+533    @Override
+534    public Future<ParseResult> parse() throws IOException, IllegalStateException {
+535        final AbstractRDFParser<T> c = prepareForParsing();
+536        return threadpool.submit(() -> {
+537            c.parseSynchronusly();
+538            return null;
+539        });
+540    }
+541
+542    @Override
+543    public T target(Consumer<Quad> consumer) {
+544        AbstractRDFParser<T> c = clone();
+545        c.resetTarget();
+546        c.target = consumer;
+547        return c.asT();
+548    }
+549
+550    @Override
+551    public T target(Dataset dataset) {
+552        @SuppressWarnings({ "rawtypes", "unchecked" })
+553        AbstractRDFParser<T> c = (AbstractRDFParser) RDFParser.super.target(dataset);
+554        c.resetTarget();
+555        c.targetDataset = Optional.of(dataset);
+556        return c.asT();
+557    }
+558
+559    @Override
+560    public T target(Graph graph) {
+561        @SuppressWarnings({ "rawtypes", "unchecked" }) // super calls our
+562                                                       // .clone()
+563        AbstractRDFParser<T> c = (AbstractRDFParser) RDFParser.super.target(graph);
+564        c.resetTarget();
+565        c.targetGraph = Optional.of(graph);
+566        return c.asT();
+567    }
+568
+569}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ + \ No newline at end of file Added: websites/production/commonsrdf/content/apidocs/src-html/org/apache/commons/rdf/simple/experimental/RDFParseException.html ============================================================================== --- websites/production/commonsrdf/content/apidocs/src-html/org/apache/commons/rdf/simple/experimental/RDFParseException.html (added) +++ websites/production/commonsrdf/content/apidocs/src-html/org/apache/commons/rdf/simple/experimental/RDFParseException.html Wed Nov 16 10:57:28 2016 @@ -0,0 +1,122 @@ + + + +Source code + + + +
+
001/**
+002 * Licensed to the Apache Software Foundation (ASF) under one
+003 * or more contributor license agreements. See the NOTICE file
+004 * distributed with this work for additional information
+005 * regarding copyright ownership. The ASF licenses this file
+006 * to you under the Apache License, Version 2.0 (the
+007 * "License"); you may not use this file except in compliance
+008 * with the License.  You may obtain a copy of the License at
+009 *
+010 *     http://www.apache.org/licenses/LICENSE-2.0
+011 *
+012 * Unless required by applicable law or agreed to in writing, software
+013 * distributed under the License is distributed on an "AS IS" BASIS,
+014 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+015 * See the License for the specific language governing permissions and
+016 * limitations under the License.
+017 */
+018
+019package org.apache.commons.rdf.simple.experimental;
+020
+021import org.apache.commons.rdf.experimental.RDFParser;
+022
+023public class RDFParseException extends Exception {
+024    private static final long serialVersionUID = 5427752643780702976L;
+025    private RDFParser builder;
+026
+027    public RDFParseException(RDFParser builder) {
+028        super();
+029        this.builder = builder;
+030    }
+031
+032    public RDFParseException(RDFParser builder, String message, Throwable cause) {
+033        super(message, cause);
+034        this.builder = builder;
+035    }
+036
+037    public RDFParseException(RDFParser builder, String message) {
+038        super(message);
+039        this.builder = builder;
+040    }
+041
+042    public RDFParseException(RDFParser builder, Throwable cause) {
+043        super(cause);
+044        this.builder = builder;
+045    }
+046
+047    public RDFParser getRDFParserBuilder() {
+048        return builder;
+049    }
+050}
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ + \ No newline at end of file Modified: websites/production/commonsrdf/content/dependencies.html ============================================================================== --- websites/production/commonsrdf/content/dependencies.html (original) +++ websites/production/commonsrdf/content/dependencies.html Wed Nov 16 10:57:28 2016 @@ -9,7 +9,7 @@ - Commons RDF API – Project Dependencies + Commons RDF impl: Simple – Project Dependencies @@ -37,7 +37,7 @@
- Commons RDF API ™ + Commons RDF impl: Simple ™
  • Last Published: 16 November 2016
    • @@ -226,7 +226,23 @@
    -

    Project Dependencies

    +

    Project Dependencies

    +
    +

    compile

    +

    The following is a list of compile dependencies for this project. These dependencies are required to compile and run the application:

    + + + + + + + + + + + + +
    GroupIdArtifactIdVersionTypeLicenses
    org.apache.commonscommons-rdf-api0.3.0-incubatingjarApache License, Version 2.0

    test

    The following is a list of test dependencies for this project. These dependencies are only required to compile and run unit tests for the application:

    @@ -235,18 +251,28 @@ GroupId ArtifactId Version +Classifier Type Licenses junit junit 4.12 +- jar Eclipse Public License 1.0 +org.apache.commons +commons-rdf-api +0.3.0-incubating +tests +jar +Apache License, Version 2.0 + org.slf4j slf4j-simple 1.7.20 +- jar MIT License
    @@ -299,7 +325,17 @@

    Dependency Tree

      -
    • org.apache.commons:commons-rdf-api:jar:0.3.0-incubating [Information]
    • org.apache.commons:commons-rdf-simple:jar:0.3.0-incubating [Information] +
        +
      • org.apache.commons:commons-rdf-api:jar:0.3.0-incubating (compile) [Information] -
          -
        • junit:junit:jar:4.12 (test) [Information]
          • +
        • org.apache.commons:commons-rdf-api:jar:tests:0.3.0-incubating (test) [Information]
          • +
        • junit:junit:jar:4.12 (test) [Information]
            -
          • org.hamcrest:hamcrest-core:jar:1.3 (test) [Information]
          • org.hamcrest:hamcrest-core:jar:1.3 (test) [Information]
          • -
        • org.slf4j:slf4j-simple:jar:1.7.20 (test) [Information]
        • org.slf4j:slf4j-simple:jar:1.7.20 (test) [Information]
            -
          • org.slf4j:slf4j-api:jar:1.7.20 (test) [Information]
          • org.slf4j:slf4j-api:jar:1.7.20 (test) [Information] +test: 5

    Dependency Repository Locations

    @@ -450,6 +518,12 @@ + + + + + + @@ -462,8 +536,8 @@ - -
    junit:junit:jar:4.12 Found at https://repo.maven.apache.org/maven2
    org.apache.commons:commons-rdf-api:jar:0.3.0-incubatingFound at https://repo.maven.apache.org/maven2
    org.apache.commons:commons-rdf-api:jar:tests:0.3.0-incubatingFound at https://repo.maven.apache.org/maven2
    org.hamcrest:hamcrest-core:jar:1.3 Found at https://repo.maven.apache.org/maven2
    Total central
    4 (test: 4)4
    +6 (compile: 1, test: 5) +6
    Modified: websites/production/commonsrdf/content/dependency-convergence.html ============================================================================== --- websites/production/commonsrdf/content/dependency-convergence.html (original) +++ websites/production/commonsrdf/content/dependency-convergence.html Wed Nov 16 10:57:28 2016 @@ -9,7 +9,7 @@ - Commons RDF API – Reactor Dependency Convergence + Commons RDF impl: Simple – Reactor Dependency Convergence @@ -37,7 +37,7 @@
    - Commons RDF API ™ + Commons RDF impl: Simple ™
    • Last Published: 16 November 2016
      • Modified: websites/production/commonsrdf/content/dependency-info.html ============================================================================== --- websites/production/commonsrdf/content/dependency-info.html (original) +++ websites/production/commonsrdf/content/dependency-info.html Wed Nov 16 10:57:28 2016 @@ -9,7 +9,7 @@ - Commons RDF API – Dependency Information + Commons RDF impl: Simple – Dependency Information @@ -37,7 +37,7 @@
      - Commons RDF API ™ + Commons RDF impl: Simple ™
      • Last Published: 16 November 2016
        • @@ -231,37 +231,37 @@ 
        <dependency>
   <groupId>org.apache.commons</groupId>
-  <artifactId>commons-rdf-api</artifactId>
+  <artifactId>commons-rdf-simple</artifactId>
   <version>0.3.0-incubating</version>
 </dependency>

      Apache Buildr

      -
      'org.apache.commons:commons-rdf-api:jar:0.3.0-incubating'
      +
      'org.apache.commons:commons-rdf-simple:jar:0.3.0-incubating'

      Apache Ivy

      -
      <dependency org="org.apache.commons" name="commons-rdf-api" rev="0.3.0-incubating">
-  <artifact name="commons-rdf-api" type="jar" />
+
      <dependency org="org.apache.commons" name="commons-rdf-simple" rev="0.3.0-incubating">
+  <artifact name="commons-rdf-simple" type="jar" />
 </dependency>

      Groovy Grape

      @Grapes(
-@Grab(group='org.apache.commons', module='commons-rdf-api', version='0.3.0-incubating')
+@Grab(group='org.apache.commons', module='commons-rdf-simple', version='0.3.0-incubating')
 )

      Gradle/Grails

      -
      compile 'org.apache.commons:commons-rdf-api:0.3.0-incubating'
      +
      compile 'org.apache.commons:commons-rdf-simple:0.3.0-incubating'

    Scala SBT

    -
    libraryDependencies += "org.apache.commons" % "commons-rdf-api" % "0.3.0-incubating"
    +
    libraryDependencies += "org.apache.commons" % "commons-rdf-simple" % "0.3.0-incubating"

Leiningen

-
[org.apache.commons/commons-rdf-api "0.3.0-incubating"]
+
[org.apache.commons/commons-rdf-simple "0.3.0-incubating"]
Modified: websites/production/commonsrdf/content/distribution-management.html ============================================================================== --- websites/production/commonsrdf/content/distribution-management.html (original) +++ websites/production/commonsrdf/content/distribution-management.html Wed Nov 16 10:57:28 2016 @@ -9,7 +9,7 @@ - Commons RDF API – Project Distribution Management + Commons RDF impl: Simple – Project Distribution Management @@ -37,7 +37,7 @@
- Commons RDF API ™ + Commons RDF impl: Simple ™
  • Last Published: 16 November 2016
    • Modified: websites/production/commonsrdf/content/findbugs.html ============================================================================== --- websites/production/commonsrdf/content/findbugs.html (original) +++ websites/production/commonsrdf/content/findbugs.html Wed Nov 16 10:57:28 2016 @@ -9,7 +9,7 @@ - Commons RDF API – FindBugs Bug Detector Report + Commons RDF impl: Simple – FindBugs Bug Detector Report @@ -37,7 +37,7 @@
    - Commons RDF API ™ + Commons RDF impl: Simple ™
    • Last Published: 16 November 2016
      • @@ -243,8 +243,8 @@ Errors Missing Classes -18 -0 +14 +1 0 0
    @@ -252,7 +252,25 @@ -
    ClassBugs
    +Bugs + +org.apache.commons.rdf.simple.DatasetGraphView +1
    +
    +

    org.apache.commons.rdf.simple.DatasetGraphView

    + + + + + + + + + + + + +
    BugCategoryDetailsLinePriority
    org.apache.commons.rdf.simple.DatasetGraphView.unionOrNamedGraph() has Optional return type and returns explicit nullCORRECTNESSNP_OPTIONAL_RETURN_NULL94High
    Modified: websites/production/commonsrdf/content/index.html ============================================================================== --- websites/production/commonsrdf/content/index.html (original) +++ websites/production/commonsrdf/content/index.html Wed Nov 16 10:57:28 2016 @@ -9,7 +9,7 @@ - Commons RDF API – About + Commons RDF impl: Simple – About @@ -37,7 +37,7 @@
    - Commons RDF API ™ + Commons RDF impl: Simple ™
    • Last Published: 16 November 2016
      • @@ -225,8 +225,8 @@
      -

      About Commons RDF API

      -

      Commons Java API for RDF 1.1

      +

      About Commons RDF impl: Simple

      +

      Simple (if not naive) implementation of Commons RDF API

    Modified: websites/production/commonsrdf/content/integration.html ============================================================================== --- websites/production/commonsrdf/content/integration.html (original) +++ websites/production/commonsrdf/content/integration.html Wed Nov 16 10:57:28 2016 @@ -9,7 +9,7 @@ - Commons RDF API – CI Management + Commons RDF impl: Simple – CI Management @@ -37,7 +37,7 @@
    - Commons RDF API ™ + Commons RDF impl: Simple ™
    • Last Published: 16 November 2016
      • Modified: websites/production/commonsrdf/content/issue-tracking.html ============================================================================== --- websites/production/commonsrdf/content/issue-tracking.html (original) +++ websites/production/commonsrdf/content/issue-tracking.html Wed Nov 16 10:57:28 2016 @@ -9,7 +9,7 @@ - Commons RDF API – Issue Management + Commons RDF impl: Simple – Issue Management @@ -37,7 +37,7 @@
      - Commons RDF API ™ + Commons RDF impl: Simple ™
      • Last Published: 16 November 2016