[Bigdata-commit] SF.net SVN: bigdata:[8040] branches/RDR/bigdata-gas/src/java/com/bigdata/ rdf/graph/analytics/PATHS.java

[<mrp...@us...>]

Revision: 8040
          http://sourceforge.net/p/bigdata/code/8040
Author:   mrpersonick
Date:     2014-04-03 22:01:57 +0000 (Thu, 03 Apr 2014)
Log Message:
-----------
bind the predecessors list to an outvar

Modified Paths:
--------------
    branches/RDR/bigdata-gas/src/java/com/bigdata/rdf/graph/analytics/PATHS.java

Modified: branches/RDR/bigdata-gas/src/java/com/bigdata/rdf/graph/analytics/PATHS.java
===================================================================
--- branches/RDR/bigdata-gas/src/java/com/bigdata/rdf/graph/analytics/PATHS.java	2014-04-03 22:01:30 UTC (rev 8039)
+++ branches/RDR/bigdata-gas/src/java/com/bigdata/rdf/graph/analytics/PATHS.java	2014-04-03 22:01:57 UTC (rev 8040)
@@ -15,6 +15,7 @@
 */
 package com.bigdata.rdf.graph.analytics;
 
+import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashSet;
 import java.util.Iterator;
@@ -309,22 +310,28 @@
             }
         });
 
-//        tmp.add(new IBinder<PATHS.VS, PATHS.ES, Void>() {
-//            
-//            @Override
-//            public int getIndex() {
-//                return Bindings.PREDECESSOR;
-//            }
-//            
-//            @Override
-//            public Value bind(final ValueFactory vf,
-//                    final IGASState<PATHS.VS, PATHS.ES, Void> state, final Value u) {
-//
-//                return state.getState(u).predecessor.get();
-//
-//            }
-//        });
+        tmp.add(new IBinder<PATHS.VS, PATHS.ES, Void>() {
+            
+            @Override
+            public int getIndex() {
+                return Bindings.PREDECESSOR;
+            }
+            
+            @Override
+            public Value bind(final ValueFactory vf,
+                    final IGASState<PATHS.VS, PATHS.ES, Void> state, final Value u) {
 
+            	final String s = Arrays.toString(state.getState(u).predecessors.toArray());
+            	
+            	if (log.isTraceEnabled()) {
+            		log.trace(s);
+            	}
+            	
+                return vf.createLiteral(s);
+
+            }
+        });
+
         return tmp;
 
     }
@@ -341,11 +348,11 @@
          */
         int DEPTH = 1;
         
-//        /**
-//         * The BFS predecessor is the first vertex to discover a given vertex.
-//         * 
-//         */
-//        int PREDECESSOR = 2;
+        /**
+         * The BFS predecessor is the first vertex to discover a given vertex.
+         * 
+         */
+        int PREDECESSOR = 2;
         
     }
 

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