|
From: <tho...@us...> - 2014-09-25 21:52:59
|
Revision: 8660
http://sourceforge.net/p/bigdata/code/8660
Author: thompsonbry
Date: 2014-09-25 21:52:55 +0000 (Thu, 25 Sep 2014)
Log Message:
-----------
Fix to scale-out DESCRIBE
Modified Paths:
--------------
branches/BIGDATA_RELEASE_1_3_0/bigdata-sails/src/java/com/bigdata/rdf/sail/webapp/BigdataRDFContext.java
Modified: branches/BIGDATA_RELEASE_1_3_0/bigdata-sails/src/java/com/bigdata/rdf/sail/webapp/BigdataRDFContext.java
===================================================================
--- branches/BIGDATA_RELEASE_1_3_0/bigdata-sails/src/java/com/bigdata/rdf/sail/webapp/BigdataRDFContext.java 2014-09-25 19:00:48 UTC (rev 8659)
+++ branches/BIGDATA_RELEASE_1_3_0/bigdata-sails/src/java/com/bigdata/rdf/sail/webapp/BigdataRDFContext.java 2014-09-25 21:52:55 UTC (rev 8660)
@@ -106,6 +106,7 @@
import com.bigdata.rdf.store.AbstractTripleStore;
import com.bigdata.rdf.task.AbstractApiTask;
import com.bigdata.relation.RelationSchema;
+import com.bigdata.service.IBigdataFederation;
import com.bigdata.sparse.ITPS;
import com.bigdata.sparse.SparseRowStore;
import com.bigdata.util.concurrent.DaemonThreadFactory;
@@ -2350,15 +2351,17 @@
}
- /*package*/ List<String> getNamespacesTx(final long tx) {
+ /*package*/ List<String> getNamespacesTx(long tx) {
-// if (timestamp == ITx.READ_COMMITTED) {
-//
-// // Use the last commit point.
-// timestamp = getIndexManager().getLastCommitTime();
-//
-// }
+ final IIndexManager indexManager = getIndexManager();
+
+ if (tx == ITx.READ_COMMITTED && indexManager instanceof IBigdataFederation) {
+ // Use the last commit point for the federation *only*.
+ tx = getIndexManager().getLastCommitTime();
+
+ }
+
// the triple store namespaces.
final List<String> namespaces = new LinkedList<String>();
This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.
|