You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by ok...@apache.org on 2016/02/06 20:54:35 UTC
[04/30] incubator-tinkerpop git commit: tweaks to filtered boolean
check.
tweaks to filtered boolean check.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/77732ddd
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/77732ddd
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/77732ddd
Branch: refs/heads/master
Commit: 77732ddd5f60bbd65a445390e590da34bea1db2f
Parents: 3485d84
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Mon Feb 1 14:59:04 2016 -0700
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Mon Feb 1 14:59:04 2016 -0700
----------------------------------------------------------------------
.../gremlin/spark/process/computer/SparkGraphComputer.java | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/77732ddd/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
----------------------------------------------------------------------
diff --git a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
index 30764b4..6606dae 100644
--- a/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
+++ b/spark-gremlin/src/main/java/org/apache/tinkerpop/gremlin/spark/process/computer/SparkGraphComputer.java
@@ -158,8 +158,10 @@ public final class SparkGraphComputer extends AbstractHadoopGraphComputer {
if (null != edgeFilter)
((GraphFilterAware) inputRDD).setEdgeFilter(this.edgeFilter);
filtered = false;
- } else {
+ } else if (null != this.vertexFilter || null != this.edgeFilter) {
filtered = true;
+ } else {
+ filtered = false;
}
} catch (final InstantiationException | IllegalAccessException e) {
throw new IllegalStateException(e.getMessage(), e);