[Bigdata-commit] SF.net SVN: bigdata:[3758] branches/QUADS_QUERY_BRANCH/bigdata-sails/src/ java/com/bigdata/rdf/sail/Rule2BOpUtility.java

[<tho...@us...>]

Revision: 3758
          http://bigdata.svn.sourceforge.net/bigdata/?rev=3758&view=rev
Author:   thompsonbry
Date:     2010-10-08 16:42:34 +0000 (Fri, 08 Oct 2010)

Log Message:
-----------
Modified to set the REMOTE_ACCESS_PATH annotation on the Predicate rather than the Join

Modified Paths:
--------------
    branches/QUADS_QUERY_BRANCH/bigdata-sails/src/java/com/bigdata/rdf/sail/Rule2BOpUtility.java

Modified: branches/QUADS_QUERY_BRANCH/bigdata-sails/src/java/com/bigdata/rdf/sail/Rule2BOpUtility.java
===================================================================
--- branches/QUADS_QUERY_BRANCH/bigdata-sails/src/java/com/bigdata/rdf/sail/Rule2BOpUtility.java	2010-10-08 16:22:13 UTC (rev 3757)
+++ branches/QUADS_QUERY_BRANCH/bigdata-sails/src/java/com/bigdata/rdf/sail/Rule2BOpUtility.java	2010-10-08 16:42:34 UTC (rev 3758)
@@ -670,15 +670,13 @@
             if (scaleOut) {
                 anns.add(new NV(Predicate.Annotations.EVALUATION_CONTEXT,
                         BOpEvaluationContext.SHARDED));
-                anns
-                        .add(new NV(Predicate.Annotations.REMOTE_ACCESS_PATH,
-                                false));
+                pred = (Predicate) pred.setProperty(
+                        Predicate.Annotations.REMOTE_ACCESS_PATH, false);
             } else {
                 anns.add(new NV(Predicate.Annotations.EVALUATION_CONTEXT,
                         BOpEvaluationContext.ANY));
-                anns
-                        .add(new NV(Predicate.Annotations.REMOTE_ACCESS_PATH,
-                                false));
+                pred = (Predicate) pred.setProperty(
+                        Predicate.Annotations.REMOTE_ACCESS_PATH, false);
             }
 
             return new PipelineJoin(new BOp[] { dataSetJoin, pred }, anns
@@ -905,15 +903,13 @@
             if (scaleOut) {
                 anns.add(new NV(Predicate.Annotations.EVALUATION_CONTEXT,
                         BOpEvaluationContext.ANY));
-                anns
-                        .add(new NV(Predicate.Annotations.REMOTE_ACCESS_PATH,
-                                true));
+                pred = (Predicate) pred.setProperty(
+                        Predicate.Annotations.REMOTE_ACCESS_PATH, false);
             } else {
                 anns.add(new NV(Predicate.Annotations.EVALUATION_CONTEXT,
                         BOpEvaluationContext.ANY));
-                anns
-                        .add(new NV(Predicate.Annotations.REMOTE_ACCESS_PATH,
-                                false));
+                pred = (Predicate) pred.setProperty(
+                        Predicate.Annotations.REMOTE_ACCESS_PATH, false);
             }
             
             return new PipelineJoin(new BOp[] { left, pred }, anns


This was sent by the SourceForge.net collaborative development platform, the world's largest Open Source development site.