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 2015/09/23 06:28:47 UTC
[3/5] incubator-tinkerpop git commit: removed more unneeded methods
with the new workerIterationStart/End work with @dkuppitz.
removed more unneeded methods with the new workerIterationStart/End work with @dkuppitz.
Project: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/commit/9f304e72
Tree: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/tree/9f304e72
Diff: http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/diff/9f304e72
Branch: refs/heads/master
Commit: 9f304e7243f3412ed81b77832dd7a7c002b1377f
Parents: 1bfdb73
Author: Marko A. Rodriguez <ok...@gmail.com>
Authored: Tue Sep 22 17:20:24 2015 -0600
Committer: Marko A. Rodriguez <ok...@gmail.com>
Committed: Tue Sep 22 17:20:24 2015 -0600
----------------------------------------------------------------------
.../gremlin/process/computer/util/MapReducePool.java | 12 ------------
.../process/computer/util/VertexProgramPool.java | 12 ------------
2 files changed, 24 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/9f304e72/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/MapReducePool.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/MapReducePool.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/MapReducePool.java
index 1efe26c..9871dc8 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/MapReducePool.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/MapReducePool.java
@@ -53,16 +53,4 @@ public final class MapReducePool {
throw new IllegalStateException(e.getMessage(), e);
}
}
-
- public synchronized void workerStart(final MapReduce.Stage stage) {
- for (final MapReduce<?, ?, ?, ?, ?> mapReduce : this.pool) {
- mapReduce.workerStart(stage);
- }
- }
-
- public synchronized void workerEnd(final MapReduce.Stage stage) {
- for (final MapReduce<?, ?, ?, ?, ?> mapReduce : this.pool) {
- mapReduce.workerEnd(stage);
- }
- }
}
http://git-wip-us.apache.org/repos/asf/incubator-tinkerpop/blob/9f304e72/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java
index b77c310..4c85387 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/computer/util/VertexProgramPool.java
@@ -54,16 +54,4 @@ public final class VertexProgramPool {
throw new IllegalStateException(e.getMessage(), e);
}
}
-
- public synchronized void workerIterationStart(final Memory memory) {
- for (final VertexProgram<?> vertexProgram : this.pool) {
- vertexProgram.workerIterationStart(memory);
- }
- }
-
- public synchronized void workerIterationEnd(final Memory memory) {
- for (final VertexProgram<?> vertexProgram : this.pool) {
- vertexProgram.workerIterationEnd(memory);
- }
- }
}