You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by an...@apache.org on 2013/09/05 17:20:08 UTC
svn commit: r1520342 - in
/jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core:
DatasetGraphWrapper.java GraphView.java
Author: andy
Date: Thu Sep 5 15:20:08 2013
New Revision: 1520342
URL: http://svn.apache.org/r1520342
Log:
Pass down sync() operations.
Modified:
jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/DatasetGraphWrapper.java
jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/GraphView.java
Modified: jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/DatasetGraphWrapper.java
URL: http://svn.apache.org/viewvc/jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/DatasetGraphWrapper.java?rev=1520342&r1=1520341&r2=1520342&view=diff
==============================================================================
--- jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/DatasetGraphWrapper.java (original)
+++ jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/DatasetGraphWrapper.java Thu Sep 5 15:20:08 2013
@@ -20,12 +20,15 @@ package com.hp.hpl.jena.sparql.core;
import java.util.Iterator ;
+import org.apache.jena.atlas.lib.Sync ;
+
import com.hp.hpl.jena.graph.Graph ;
import com.hp.hpl.jena.graph.Node ;
import com.hp.hpl.jena.shared.Lock ;
+import com.hp.hpl.jena.sparql.SystemARQ ;
import com.hp.hpl.jena.sparql.util.Context ;
-public class DatasetGraphWrapper implements DatasetGraph
+public class DatasetGraphWrapper implements DatasetGraph, Sync
{
private final DatasetGraph dsg ;
public final DatasetGraph getWrapped() { return dsg ; }
@@ -129,4 +132,11 @@ public class DatasetGraphWrapper impleme
@Override
public String toString() { return dsg.toString() ; }
+
+ @Override
+ public void sync() {
+ // Pass down sync.
+ SystemARQ.sync(dsg) ;
+ }
+
}
Modified: jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/GraphView.java
URL: http://svn.apache.org/viewvc/jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/GraphView.java?rev=1520342&r1=1520341&r2=1520342&view=diff
==============================================================================
--- jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/GraphView.java (original)
+++ jena/trunk/jena-arq/src/main/java/com/hp/hpl/jena/sparql/core/GraphView.java Thu Sep 5 15:20:08 2013
@@ -21,6 +21,7 @@ package com.hp.hpl.jena.sparql.core;
import java.util.Iterator ;
import org.apache.jena.atlas.iterator.Iter ;
+import org.apache.jena.atlas.lib.Sync ;
import org.apache.jena.riot.other.GLib ;
import com.hp.hpl.jena.graph.Node ;
@@ -30,14 +31,16 @@ import com.hp.hpl.jena.graph.impl.GraphB
import com.hp.hpl.jena.shared.JenaException ;
import com.hp.hpl.jena.shared.PrefixMapping ;
import com.hp.hpl.jena.shared.impl.PrefixMappingImpl ;
+import com.hp.hpl.jena.sparql.SystemARQ ;
import com.hp.hpl.jena.util.iterator.ExtendedIterator ;
import com.hp.hpl.jena.util.iterator.WrappedIterator ;
/** Implement a Graph as a view of the DatasetGraph.
*
- * It maps graph operations to quad operations. */
+ * It maps graph operations to quad operations.
+ */
-public class GraphView extends GraphBase
+public class GraphView extends GraphBase implements Sync
{
// Beware this implements union graph - implementations may wish
// to do better so see protected method below.
@@ -147,4 +150,9 @@ public class GraphView extends GraphBase
Node o = t.getObject() ;
dsg.delete(g, s, p, o) ;
}
+
+ @Override
+ public void sync() {
+ SystemARQ.sync(dsg);
+ }
}