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 72325200BAC for ; Wed, 26 Oct 2016 13:35:38 +0200 (CEST) Received: by cust-asf.ponee.io (Postfix) id 70FFE160B07; Wed, 26 Oct 2016 11:35:38 +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 F28A2160ACA for ; Wed, 26 Oct 2016 13:35:36 +0200 (CEST) Received: (qmail 58730 invoked by uid 500); 26 Oct 2016 11:35:36 -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 58720 invoked by uid 99); 26 Oct 2016 11:35:36 -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, 26 Oct 2016 11:35:36 +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 BC480C709D for ; Wed, 26 Oct 2016 11:35:35 +0000 (UTC) X-Virus-Scanned: Debian amavisd-new at spamd1-us-west.apache.org X-Spam-Flag: NO X-Spam-Score: -6.219 X-Spam-Level: X-Spam-Status: No, score=-6.219 tagged_above=-999 required=6.31 tests=[KAM_ASCII_DIVIDERS=0.8, KAM_LAZY_DOMAIN_SECURITY=1, RCVD_IN_DNSWL_HI=-5, RCVD_IN_MSPIKE_H3=-0.01, RCVD_IN_MSPIKE_WL=-0.01, RP_MATCHES_RCVD=-2.999] autolearn=disabled Received: from mx1-lw-eu.apache.org ([10.40.0.8]) by localhost (spamd1-us-west.apache.org [10.40.0.7]) (amavisd-new, port 10024) with ESMTP id 8DgA6pva_Fft for ; Wed, 26 Oct 2016 11:35:32 +0000 (UTC) Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by mx1-lw-eu.apache.org (ASF Mail Server at mx1-lw-eu.apache.org) with SMTP id 106845FC99 for ; Wed, 26 Oct 2016 11:35:29 +0000 (UTC) Received: (qmail 57124 invoked by uid 99); 26 Oct 2016 11:35:28 -0000 Received: from git1-us-west.apache.org (HELO git1-us-west.apache.org) (140.211.11.23) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 26 Oct 2016 11:35:28 +0000 Received: by git1-us-west.apache.org (ASF Mail Server at git1-us-west.apache.org, from userid 33) id 6AE2DDFC70; Wed, 26 Oct 2016 11:35:28 +0000 (UTC) Content-Type: text/plain; charset="us-ascii" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit From: stain@apache.org To: commits@commonsrdf.incubator.apache.org Date: Wed, 26 Oct 2016 11:36:15 -0000 Message-Id: <15eff01081c943f380dbf1b4b791afd9@git.apache.org> In-Reply-To: <79f4c1e3004742eb84ed29d28b59c3f4@git.apache.org> References: <79f4c1e3004742eb84ed29d28b59c3f4@git.apache.org> X-Mailer: ASF-Git Admin Mailer Subject: [49/50] [abbrv] incubator-commonsrdf git commit: fromJena/toJena -> as* / asJena* archived-at: Wed, 26 Oct 2016 11:35:38 -0000 fromJena/toJena -> as* / asJena* Project: http://git-wip-us.apache.org/repos/asf/incubator-commonsrdf/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-commonsrdf/commit/5c190d21 Tree: http://git-wip-us.apache.org/repos/asf/incubator-commonsrdf/tree/5c190d21 Diff: http://git-wip-us.apache.org/repos/asf/incubator-commonsrdf/diff/5c190d21 Branch: refs/heads/master Commit: 5c190d2104db3b64bd87b7520f9d45859e5805d9 Parents: 6fdc990 Author: Stian Soiland-Reyes Authored: Wed Oct 26 12:30:51 2016 +0100 Committer: Stian Soiland-Reyes Committed: Wed Oct 26 12:30:51 2016 +0100 ---------------------------------------------------------------------- .../apache/commons/rdf/jena/JenaFactory.java | 150 ++++++++++--------- .../rdf/jena/experimental/JenaRDFParser.java | 4 +- .../commons/rdf/jena/impl/AbstractQuadLike.java | 28 ++-- .../rdf/jena/impl/InternalJenaFactory.java | 72 ++++----- .../commons/rdf/jena/impl/JenaDatasetImpl.java | 28 ++-- .../commons/rdf/jena/impl/JenaGraphImpl.java | 30 ++-- .../jena/TestJenaGraphToCommonsRDFGraph.java | 2 +- 7 files changed, 164 insertions(+), 150 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-commonsrdf/blob/5c190d21/jena/src/main/java/org/apache/commons/rdf/jena/JenaFactory.java ---------------------------------------------------------------------- diff --git a/jena/src/main/java/org/apache/commons/rdf/jena/JenaFactory.java b/jena/src/main/java/org/apache/commons/rdf/jena/JenaFactory.java index 0d735c7..f2c65df 100644 --- a/jena/src/main/java/org/apache/commons/rdf/jena/JenaFactory.java +++ b/jena/src/main/java/org/apache/commons/rdf/jena/JenaFactory.java @@ -50,11 +50,25 @@ import org.apache.jena.sparql.graph.GraphFactory; /** * RDFTermFactory with Jena-backed objects. *

- * This factory can also convert existing objects from/to Jena with methods like - * {@link #fromJena(org.apache.jena.graph.Graph)} and {@link #toJena(Graph)}. + * This factory can also convert existing objects from Jena with methods like + * {@link #asRDFTerm(Node)} and {@link #asGraph(org.apache.jena.graph.Graph)}, + * and vice versa from any Commons RDF object to Jena with the + * asJena* methods like {@link #asJenaNode(RDFTerm)} and + * {@link #asJenaGraph(Graph)}. *

- * For the purpose of {@link BlankNode} identity, this factory will use an internal - * {@link UUID} as a salt. See {@link BlankNode#uniqueReference()} for details. + * Note that Commons RDF objects created by this class implement the + * specializations interfaces like {@link JenaRDFTerm}, {@link JenaGraph} and + * {@link JenaTriple}, which provide access to the underlying Jena objects, e.g. + * with {@link JenaRDFTerm#asJenaNode()}. + *

+ * For the purpose of {@link BlankNode} identity when using + * {@link #createBlankNode(String)} (see {@link BlankNode#equals(Object)} and + * {@link BlankNode#uniqueReference()}), each instance of this factory uses an + * internal random state. If for some reason consistent/reproducible BlankNode + * identity is desired, it is possible to retrieve the state as a UUID using + * {@link #salt} for subsequent use with {@link JenaFactory#JenaFactory(UUID)} - + * note that such consistency is only guaranteed within the same minor version + * of Commons RDF. * * @see RDFTermFactory */ @@ -68,7 +82,7 @@ public final class JenaFactory implements RDFTermFactory { * Create a JenaFactory. *

* This constructor will use a randomly generated {@link UUID} as a salt - * for the purposes of {@link BlankNode} identity, see {@link #getSalt()}. + * for the purposes of {@link BlankNode} identity, see {@link #salt()}. */ public JenaFactory() { this.salt = UUID.randomUUID(); @@ -91,22 +105,22 @@ public final class JenaFactory implements RDFTermFactory { @Override public JenaBlankNode createBlankNode() { - return internalJenaFactory.createBlankNode(getSalt()); + return internalJenaFactory.createBlankNode(salt()); } @Override public JenaBlankNode createBlankNode(String name) { - return internalJenaFactory.createBlankNode(name, getSalt()); + return internalJenaFactory.createBlankNode(name, salt()); } @Override public JenaDataset createDataset() { - return internalJenaFactory.createDataset(getSalt()); + return internalJenaFactory.createDataset(salt()); } @Override public JenaGraph createGraph() { - return internalJenaFactory.createGraph(getSalt()); + return internalJenaFactory.createGraph(salt()); } @Override @@ -203,7 +217,7 @@ public final class JenaFactory implements RDFTermFactory { * {@link Node#getBlankNodeId()} for the purpose of its * {@link BlankNode#uniqueReference()}. * - * @see #fromJena(RDFTermFactory, Node) + * @see #asRDFTerm(RDFTermFactory, Node) * * @param node * The Jena Node to adapt. It's {@link Node#isConcrete()} must be @@ -212,8 +226,8 @@ public final class JenaFactory implements RDFTermFactory { * @throws ConversionException If the {@link Node} can't be represented as an {@link RDFTerm}, e.g. * if the node is not concrete or represents a variable in Jena. */ - public JenaRDFTerm fromJena(Node node) throws ConversionException { - return internalJenaFactory.fromJena(node, getSalt()); + public JenaRDFTerm asRDFTerm(Node node) throws ConversionException { + return internalJenaFactory.createRDFTerm(node, salt()); } /** @@ -224,7 +238,7 @@ public final class JenaFactory implements RDFTermFactory { * that care should be taken if reusing an {@link RDFTermFactory} instance * for multiple conversion sessions. * - * @see #fromJena(Node) + * @see #asRDFTerm(Node) * * @param factory {@link RDFTermFactory} to use for creating {@link RDFTerm}. * @param node @@ -234,13 +248,13 @@ public final class JenaFactory implements RDFTermFactory { * @throws ConversionException If the {@link Node} can't be represented as an {@link RDFTerm}, e.g. * if the node is not concrete or represents a variable in Jena. */ - public static RDFTerm fromJena(RDFTermFactory factory, Node node) { + public static RDFTerm asRDFTerm(RDFTermFactory factory, Node node) { if (node == null) { return null; } if (factory instanceof JenaFactory) { // No need to convert, just wrap - return ((JenaFactory) factory).fromJena(node); + return ((JenaFactory) factory).asRDFTerm(node); } if (node.isURI()) return factory.createIRI(node.getURI()); @@ -268,7 +282,7 @@ public final class JenaFactory implements RDFTermFactory { * {@link Node#getBlankNodeId()} for the purpose of its * {@link BlankNode#uniqueReference()}. * - * @see #fromJena(RDFTermFactory, org.apache.jena.graph.Triple) + * @see #asTriple(RDFTermFactory, org.apache.jena.graph.Triple) * * @param triple * Jena {@link org.apache.jena.graph.Triple} to adapt @@ -277,8 +291,8 @@ public final class JenaFactory implements RDFTermFactory { * if any of the triple's nodes are not concrete or the triple * is a generalized triple */ - public JenaTriple fromJena(org.apache.jena.graph.Triple triple) throws ConversionException { - return internalJenaFactory.fromJena(triple, getSalt()); + public JenaTriple asTriple(org.apache.jena.graph.Triple triple) throws ConversionException { + return internalJenaFactory.createTriple(triple, salt()); } /** @@ -293,7 +307,7 @@ public final class JenaFactory implements RDFTermFactory { * {@link Node#getBlankNodeId()} for the purpose of its * {@link BlankNode#uniqueReference()}. * - * @see #fromJena(RDFTermFactory, org.apache.jena.graph.Triple) + * @see #asTriple(RDFTermFactory, org.apache.jena.graph.Triple) * * @param triple * Jena triple @@ -303,8 +317,8 @@ public final class JenaFactory implements RDFTermFactory { * @throws ConversionException * if any of the triple's nodes are not concrete */ - public JenaTripleLike fromJenaGeneralized(org.apache.jena.graph.Triple triple) throws ConversionException { - return internalJenaFactory.fromJenaGeneralized(triple, getSalt()); + public JenaTripleLike asGeneralizedTriple(org.apache.jena.graph.Triple triple) throws ConversionException { + return internalJenaFactory.createGeneralizedTriple(triple, salt()); } /** @@ -322,8 +336,8 @@ public final class JenaFactory implements RDFTermFactory { * {@link Node#getBlankNodeId()} for the purpose of its * {@link BlankNode#uniqueReference()}. * - * @see #fromJena(org.apache.jena.sparql.core.Quad) - * @see #fromJenaGeneralized(org.apache.jena.graph.Triple) + * @see #asQuad(org.apache.jena.sparql.core.Quad) + * @see #asGeneralizedTriple(org.apache.jena.graph.Triple) * * @param quad * Jena quad @@ -333,8 +347,8 @@ public final class JenaFactory implements RDFTermFactory { * @throws ConversionException * if any of the quad nodes are not concrete */ - public JenaQuadLike fromJenaGeneralized(org.apache.jena.sparql.core.Quad quad) throws ConversionException { - return internalJenaFactory.fromJenaGeneralized(quad, getSalt()); + public JenaQuadLike asGeneralizedQuad(org.apache.jena.sparql.core.Quad quad) throws ConversionException { + return internalJenaFactory.createGeneralizedQuad(quad, salt()); } /** @@ -346,7 +360,7 @@ public final class JenaFactory implements RDFTermFactory { * that care should be taken if reusing an {@link RDFTermFactory} instance * for multiple conversion sessions. * - * @see #fromJena(org.apache.jena.graph.Triple) + * @see #asTriple(org.apache.jena.graph.Triple) * * @param factory {@link RDFTermFactory} to use for creating the {@link Triple} and its * {@link RDFTerm}s. @@ -357,21 +371,21 @@ public final class JenaFactory implements RDFTermFactory { * if any of the triple's nodes are not concrete or the triple * is a generalized triple */ - public static Triple fromJena(RDFTermFactory factory, org.apache.jena.graph.Triple triple) + public static Triple asTriple(RDFTermFactory factory, org.apache.jena.graph.Triple triple) throws ConversionException{ if (factory instanceof JenaFactory) { // No need to convert, just wrap - return ((JenaFactory) factory).fromJena(triple); + return ((JenaFactory) factory).asTriple(triple); } final BlankNodeOrIRI subject; final IRI predicate; try { - subject = (BlankNodeOrIRI) fromJena(factory, triple.getSubject()); - predicate = (IRI) fromJena(factory, triple.getPredicate()); + subject = (BlankNodeOrIRI) asRDFTerm(factory, triple.getSubject()); + predicate = (IRI) asRDFTerm(factory, triple.getPredicate()); } catch (ClassCastException ex) { throw new ConversionException("Can't convert generalized triple: " + triple, ex); } - RDFTerm object = fromJena(factory, triple.getObject()); + RDFTerm object = asRDFTerm(factory, triple.getObject()); return factory.createTriple(subject, predicate, object); } @@ -388,8 +402,8 @@ public final class JenaFactory implements RDFTermFactory { * Jena quad * @return Adapted quad */ - public JenaQuad fromJena(org.apache.jena.sparql.core.Quad quad) { - return internalJenaFactory.fromJena(quad, getSalt()); + public JenaQuad asQuad(org.apache.jena.sparql.core.Quad quad) { + return internalJenaFactory.createQuad(quad, salt()); } /** @@ -410,8 +424,8 @@ public final class JenaFactory implements RDFTermFactory { * Jena {@link org.apache.jena.graph.Graph} to adapt * @return Adapted {@link JenaGraph} */ - public JenaGraph fromJena(org.apache.jena.graph.Graph graph) { - return internalJenaFactory.fromJena(graph, getSalt()); + public JenaGraph asGraph(org.apache.jena.graph.Graph graph) { + return internalJenaFactory.createGraph(graph, salt()); } /** @@ -429,8 +443,8 @@ public final class JenaFactory implements RDFTermFactory { * Jena {@link org.apache.jena.rdf.model.Model} to adapt * @return Adapted {@link JenaGraph} */ - public JenaGraph fromJena(org.apache.jena.rdf.model.Model model) { - return internalJenaFactory.fromJena(model, getSalt()); + public JenaGraph asGraph(org.apache.jena.rdf.model.Model model) { + return internalJenaFactory.createGraph(model, salt()); } /** @@ -449,8 +463,8 @@ public final class JenaFactory implements RDFTermFactory { * @param datasetGraph Jena {@link DatasetGraph} to adapt * @return Adapted {@link JenaDataset} */ - public JenaDataset fromJena(DatasetGraph datasetGraph) { - return internalJenaFactory.fromJena(datasetGraph, getSalt()); + public JenaDataset asDataset(DatasetGraph datasetGraph) { + return internalJenaFactory.createDataset(datasetGraph, salt()); } /** @@ -469,8 +483,8 @@ public final class JenaFactory implements RDFTermFactory { * @param datasetGraph Jena {@link org.apache.jena.query.Dataset} to adapt * @return Adapted {@link JenaDataset} */ - public JenaDataset fromJena(org.apache.jena.query.Dataset datasetGraph) { - return internalJenaFactory.fromJena(datasetGraph.asDatasetGraph(), getSalt()); + public JenaDataset asDataset(org.apache.jena.query.Dataset datasetGraph) { + return internalJenaFactory.createDataset(datasetGraph.asDatasetGraph(), salt()); } /** @@ -482,8 +496,8 @@ public final class JenaFactory implements RDFTermFactory { * meaning that care should be taken if reusing an {@link RDFTermFactory} * instance for multiple conversion sessions. * - * @see #fromJena(org.apache.jena.sparql.core.Quad) - * @see #fromJenaGeneralized(org.apache.jena.sparql.core.Quad) + * @see #asQuad(org.apache.jena.sparql.core.Quad) + * @see #asGeneralizedQuad(org.apache.jena.sparql.core.Quad) * * @param factory * {@link RDFTermFactory} to use for creating the {@link Triple} @@ -495,15 +509,15 @@ public final class JenaFactory implements RDFTermFactory { * if any of the quad's nodes are not concrete or the quad * is a generalized quad */ - public static Quad fromJena(RDFTermFactory factory, org.apache.jena.sparql.core.Quad quad) { + public static Quad asQuad(RDFTermFactory factory, org.apache.jena.sparql.core.Quad quad) { if (factory instanceof JenaFactory) { // No need to convert, just wrap - return ((JenaFactory) factory).fromJena(quad); + return ((JenaFactory) factory).asQuad(quad); } - BlankNodeOrIRI graphName = (BlankNodeOrIRI) (fromJena(factory, quad.getGraph())); - BlankNodeOrIRI subject = (BlankNodeOrIRI) (fromJena(factory, quad.getSubject())); - IRI predicate = (IRI) (fromJena(factory, quad.getPredicate())); - RDFTerm object = fromJena(factory, quad.getObject()); + BlankNodeOrIRI graphName = (BlankNodeOrIRI) (asRDFTerm(factory, quad.getGraph())); + BlankNodeOrIRI subject = (BlankNodeOrIRI) (asRDFTerm(factory, quad.getSubject())); + IRI predicate = (IRI) (asRDFTerm(factory, quad.getPredicate())); + RDFTerm object = asRDFTerm(factory, quad.getObject()); return factory.createQuad(graphName, subject, predicate, object); } @@ -513,7 +527,7 @@ public final class JenaFactory implements RDFTermFactory { * @param lang {@link Lang} to convert * @return Matched {@link RDFSyntax}, otherwise {@link Optional#empty()} */ - public Optional langToRdfSyntax(Lang lang) { + public Optional asRDFSyntax(Lang lang) { return RDFSyntax.byMediaType(lang.getContentType().getContentType()); } @@ -523,7 +537,7 @@ public final class JenaFactory implements RDFTermFactory { * @param rdfSyntax {@link RDFSyntax} to convert * @return Matched {@link Lang}, otherwise {@link Optional#empty()} */ - public Optional rdfSyntaxToLang(RDFSyntax rdfSyntax) { + public Optional asJenaLang(RDFSyntax rdfSyntax) { return Optional.ofNullable(RDFLanguages.contentTypeToLang(rdfSyntax.mediaType)); } @@ -542,11 +556,11 @@ public final class JenaFactory implements RDFTermFactory { * @return A {@link StreamRDF} that will stream converted quads to the * consumer */ - public static StreamRDF streamJenaToCommonsRDF(RDFTermFactory factory, Consumer consumer) { + public static StreamRDF streamJenaToQuad(RDFTermFactory factory, Consumer consumer) { return new StreamRDFBase() { @Override public void quad(org.apache.jena.sparql.core.Quad quad) { - consumer.accept(fromJena(factory, quad)); + consumer.accept(asQuad(factory, quad)); } }; } @@ -571,7 +585,7 @@ public final class JenaFactory implements RDFTermFactory { return new StreamRDFBase() { @Override public void triple(org.apache.jena.graph.Triple triple) { - generalizedConsumer.accept(fromJenaGeneralized(triple)); + generalizedConsumer.accept(asGeneralizedTriple(triple)); } }; } @@ -596,7 +610,7 @@ public final class JenaFactory implements RDFTermFactory { return new StreamRDFBase() { @Override public void quad(org.apache.jena.sparql.core.Quad quad) { - generalizedConsumer.accept(fromJenaGeneralized(quad)); + generalizedConsumer.accept(asGeneralizedQuad(quad)); } }; } @@ -609,11 +623,11 @@ public final class JenaFactory implements RDFTermFactory { * @param graph Commons RDF {@link Graph} to convert * @return Converted Jena {@link org.apache.jena.graph.Graph} */ - public org.apache.jena.graph.Graph toJena(Graph graph) { + public org.apache.jena.graph.Graph asJenaGraph(Graph graph) { if (graph instanceof JenaGraph) return ((JenaGraph) graph).asJenaGraph(); org.apache.jena.graph.Graph g = GraphFactory.createGraphMem(); - graph.stream().forEach(t -> g.add(toJena(t))); + graph.stream().forEach(t -> g.add(asJenaTriple(t))); return g; } @@ -625,7 +639,7 @@ public final class JenaFactory implements RDFTermFactory { * @param term Commons RDF {@link RDFTerm} to convert * @return Converted Jena {@link Node} */ - public Node toJena(RDFTerm term) { + public Node asJenaNode(RDFTerm term) { if (term == null) { return null; } @@ -662,13 +676,13 @@ public final class JenaFactory implements RDFTermFactory { * @param triple Commons RDF {@link Triple} to convert * @return Converted Jena {@link org.apache.jena.graph.Triple} */ - public org.apache.jena.graph.Triple toJena(Triple triple) { + public org.apache.jena.graph.Triple asJenaTriple(Triple triple) { if (triple instanceof JenaTriple) return ((JenaTriple) triple).asJenaTriple(); return org.apache.jena.graph.Triple.create( - toJena(triple.getSubject()), - toJena(triple.getPredicate()), - toJena(triple.getObject())); + asJenaNode(triple.getSubject()), + asJenaNode(triple.getPredicate()), + asJenaNode(triple.getObject())); } @@ -682,15 +696,15 @@ public final class JenaFactory implements RDFTermFactory { * @param quad Commons RDF {@link Quad} to convert * @return Converted Jena {@link org.apache.jena.sparql.core.Quad} */ - public org.apache.jena.sparql.core.Quad toJena(Quad quad) { + public org.apache.jena.sparql.core.Quad asJenaQuad(Quad quad) { if (quad instanceof JenaQuad) { return ((JenaQuad) quad).asJenaQuad(); } return org.apache.jena.sparql.core.Quad.create( - toJena(quad.getGraphName().orElse(null)), - toJena(quad.getSubject()), - toJena(quad.getPredicate()), - toJena(quad.getObject())); + asJenaNode(quad.getGraphName().orElse(null)), + asJenaNode(quad.getSubject()), + asJenaNode(quad.getPredicate()), + asJenaNode(quad.getObject())); } // Some simple validations - full IRI parsing is not cheap. @@ -720,7 +734,7 @@ public final class JenaFactory implements RDFTermFactory { * * @return The {@link UUID} used as salt */ - public UUID getSalt() { + public UUID salt() { return salt; } http://git-wip-us.apache.org/repos/asf/incubator-commonsrdf/blob/5c190d21/jena/src/main/java/org/apache/commons/rdf/jena/experimental/JenaRDFParser.java ---------------------------------------------------------------------- diff --git a/jena/src/main/java/org/apache/commons/rdf/jena/experimental/JenaRDFParser.java b/jena/src/main/java/org/apache/commons/rdf/jena/experimental/JenaRDFParser.java index 19a8a63..14d13d9 100644 --- a/jena/src/main/java/org/apache/commons/rdf/jena/experimental/JenaRDFParser.java +++ b/jena/src/main/java/org/apache/commons/rdf/jena/experimental/JenaRDFParser.java @@ -81,11 +81,11 @@ public class JenaRDFParser extends AbstractRDFParser implements R } else if (generalizedConsumerTriple != null) { dest = jenaFactory.streamJenaToGeneralizedTriple(generalizedConsumerTriple); } else { - dest = JenaFactory.streamJenaToCommonsRDF(getRdfTermFactory().get(), getTarget()); + dest = JenaFactory.streamJenaToQuad(getRdfTermFactory().get(), getTarget()); } } - Lang lang = getContentTypeSyntax().flatMap(jenaFactory::rdfSyntaxToLang).orElse(null); + Lang lang = getContentTypeSyntax().flatMap(jenaFactory::asJenaLang).orElse(null); String baseStr = getBase().map(IRI::getIRIString).orElse(null); if (getSourceIri().isPresent()) { http://git-wip-us.apache.org/repos/asf/incubator-commonsrdf/blob/5c190d21/jena/src/main/java/org/apache/commons/rdf/jena/impl/AbstractQuadLike.java ---------------------------------------------------------------------- diff --git a/jena/src/main/java/org/apache/commons/rdf/jena/impl/AbstractQuadLike.java b/jena/src/main/java/org/apache/commons/rdf/jena/impl/AbstractQuadLike.java index c66a1da..9166731 100644 --- a/jena/src/main/java/org/apache/commons/rdf/jena/impl/AbstractQuadLike.java +++ b/jena/src/main/java/org/apache/commons/rdf/jena/impl/AbstractQuadLike.java @@ -69,18 +69,18 @@ abstract class AbstractQuadLike stream() { JenaFactory factory = new JenaFactory(salt); return Iter.asStream(graph.find(ANY, ANY, ANY, ANY), true) - .map(factory::fromJena); + .map(factory::asQuad); } @Override public Stream stream(Optional g, BlankNodeOrIRI s, IRI p, RDFTerm o) { JenaFactory factory = new JenaFactory(salt); return Iter.asStream(graph.find(toJenaPattern(g), toJenaPattern(s), toJenaPattern(p), toJenaPattern(o)), true) - .map(factory::fromJena); + .map(factory::asQuad); } @Override @@ -169,7 +169,7 @@ class JenaDatasetImpl implements JenaDataset { @Override public Optional getGraph(BlankNodeOrIRI graphName) { - GraphView gv = GraphView.createNamedGraph(graph, factory.toJena(graphName)); + GraphView gv = GraphView.createNamedGraph(graph, factory.asJenaNode(graphName)); return Optional.of(new JenaGraphImpl(gv, salt)); } @@ -177,14 +177,14 @@ class JenaDatasetImpl implements JenaDataset { public Stream getGraphNames() { JenaFactory factory = new JenaFactory(salt); return Iter.asStream(graph.listGraphNodes()).map(node -> - (BlankNodeOrIRI) factory.fromJena(node)); + (BlankNodeOrIRI) factory.asRDFTerm(node)); } @Override public Iterable iterate() { final JenaFactory factory = new JenaFactory(salt); return Iter.asStream(graph.find(), false) - .map(q -> (Quad) factory.fromJena(q)) + .map(q -> (Quad) factory.asQuad(q)) ::iterator; } http://git-wip-us.apache.org/repos/asf/incubator-commonsrdf/blob/5c190d21/jena/src/main/java/org/apache/commons/rdf/jena/impl/JenaGraphImpl.java ---------------------------------------------------------------------- diff --git a/jena/src/main/java/org/apache/commons/rdf/jena/impl/JenaGraphImpl.java b/jena/src/main/java/org/apache/commons/rdf/jena/impl/JenaGraphImpl.java index bad996a..ab56505 100644 --- a/jena/src/main/java/org/apache/commons/rdf/jena/impl/JenaGraphImpl.java +++ b/jena/src/main/java/org/apache/commons/rdf/jena/impl/JenaGraphImpl.java @@ -58,14 +58,14 @@ class JenaGraphImpl implements JenaGraph { @Override public void add(BlankNodeOrIRI subject, IRI predicate, RDFTerm object) { graph.add(org.apache.jena.graph.Triple.create( - factory.toJena(subject), - factory.toJena(predicate), - factory.toJena(object))); + factory.asJenaNode(subject), + factory.asJenaNode(predicate), + factory.asJenaNode(object))); } @Override public void add(Triple triple) { - graph.add(factory.toJena(triple)); + graph.add(factory.asJenaTriple(triple)); } @Override @@ -86,27 +86,27 @@ class JenaGraphImpl implements JenaGraph { @Override public boolean contains(BlankNodeOrIRI subject, IRI predicate, RDFTerm object) { return graph.contains( - factory.toJena(subject), - factory.toJena(predicate), - factory.toJena(object)); + factory.asJenaNode(subject), + factory.asJenaNode(predicate), + factory.asJenaNode(object)); } @Override public boolean contains(Triple triple) { - return graph.contains(factory.toJena(triple)); + return graph.contains(factory.asJenaTriple(triple)); } @Override public void remove(BlankNodeOrIRI subject, IRI predicate, RDFTerm object) { graph.delete(org.apache.jena.graph.Triple.create( - factory.toJena(subject), - factory.toJena(predicate), - factory.toJena(object))); + factory.asJenaNode(subject), + factory.asJenaNode(predicate), + factory.asJenaNode(object))); } @Override public void remove(Triple triple) { - graph.delete(factory.toJena(triple)); + graph.delete(factory.asJenaTriple(triple)); } @Override @@ -117,20 +117,20 @@ class JenaGraphImpl implements JenaGraph { @Override public Stream stream() { JenaFactory factory = new JenaFactory(salt); - return Iter.asStream(graph.find(null, null, null), true).map(factory::fromJena); + return Iter.asStream(graph.find(null, null, null), true).map(factory::asTriple); } @Override public Stream stream(BlankNodeOrIRI s, IRI p, RDFTerm o) { JenaFactory factory = new JenaFactory(salt); return Iter.asStream(graph.find(toJenaAny(s), toJenaAny(p), toJenaAny(o)), true) - .map(factory::fromJena); + .map(factory::asTriple); } private Node toJenaAny(RDFTerm term) { if (term == null) return Node.ANY; - return factory.toJena(term); + return factory.asJenaNode(term); } @Override http://git-wip-us.apache.org/repos/asf/incubator-commonsrdf/blob/5c190d21/jena/src/test/java/org/apache/commons/rdf/jena/TestJenaGraphToCommonsRDFGraph.java ---------------------------------------------------------------------- diff --git a/jena/src/test/java/org/apache/commons/rdf/jena/TestJenaGraphToCommonsRDFGraph.java b/jena/src/test/java/org/apache/commons/rdf/jena/TestJenaGraphToCommonsRDFGraph.java index 050de4e..393bc8f 100644 --- a/jena/src/test/java/org/apache/commons/rdf/jena/TestJenaGraphToCommonsRDFGraph.java +++ b/jena/src/test/java/org/apache/commons/rdf/jena/TestJenaGraphToCommonsRDFGraph.java @@ -67,7 +67,7 @@ public class TestJenaGraphToCommonsRDFGraph { JenaFactory factory = new JenaFactory() ; // "graph" is a CommonsRDF graph - Graph graph = factory.fromJena(jGraph) ; + Graph graph = factory.asGraph(jGraph) ;