You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@tinkerpop.apache.org by sp...@apache.org on 2017/10/25 11:58:08 UTC
tinkerpop git commit: TINKERPOP-1808 Added getters for the lambda
held by these steps. CTR
Repository: tinkerpop
Updated Branches:
refs/heads/tp32 f1c41ea49 -> c0a03ca0a
TINKERPOP-1808 Added getters for the lambda held by these steps. CTR
Project: http://git-wip-us.apache.org/repos/asf/tinkerpop/repo
Commit: http://git-wip-us.apache.org/repos/asf/tinkerpop/commit/c0a03ca0
Tree: http://git-wip-us.apache.org/repos/asf/tinkerpop/tree/c0a03ca0
Diff: http://git-wip-us.apache.org/repos/asf/tinkerpop/diff/c0a03ca0
Branch: refs/heads/tp32
Commit: c0a03ca0ac57997895b6f867e5df109433cc35a5
Parents: f1c41ea
Author: Stephen Mallette <sp...@genoprime.com>
Authored: Wed Oct 25 07:57:03 2017 -0400
Committer: Stephen Mallette <sp...@genoprime.com>
Committed: Wed Oct 25 07:57:03 2017 -0400
----------------------------------------------------------------------
CHANGELOG.asciidoc | 1 +
.../process/traversal/step/map/LambdaCollectingBarrierStep.java | 4 ++++
.../gremlin/process/traversal/step/map/LambdaFlatMapStep.java | 4 ++++
.../process/traversal/step/sideEffect/LambdaSideEffectStep.java | 4 ++++
4 files changed, 13 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/c0a03ca0/CHANGELOG.asciidoc
----------------------------------------------------------------------
diff --git a/CHANGELOG.asciidoc b/CHANGELOG.asciidoc
index 12f75d9..555eceb 100644
--- a/CHANGELOG.asciidoc
+++ b/CHANGELOG.asciidoc
@@ -23,6 +23,7 @@ image::https://raw.githubusercontent.com/apache/tinkerpop/master/docs/static/ima
[[release-3-2-7]]
=== TinkerPop 3.2.7 (Release Date: NOT OFFICIALLY RELEASED YET)
+* Added getters for the lambdas held by `LambdaCollectingBarrierStep`, `LambdaFlatMapStep` and `LambdaSideEffectStep`.
* Fixed an old hack in `GroovyTranslator` and `PythonTranslator` where `Elements` were being mapped to their id only.
* Fixed an "attachement"-bug in `InjectStep` with a solution generalized to `StartStep`.
* Truncate the script in error logs and error return messages for "Method code too large" errors in Gremlin Server.
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/c0a03ca0/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaCollectingBarrierStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaCollectingBarrierStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaCollectingBarrierStep.java
index 8ffe2b3..9b500d4 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaCollectingBarrierStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaCollectingBarrierStep.java
@@ -52,6 +52,10 @@ public final class LambdaCollectingBarrierStep<S> extends CollectingBarrierStep<
this.barrierConsumer = barrierConsumer;
}
+ public Consumer<TraverserSet<S>> getBarrierConsumer() {
+ return barrierConsumer;
+ }
+
@Override
public void barrierConsumer(final TraverserSet<S> traverserSet) {
this.barrierConsumer.accept(traverserSet);
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/c0a03ca0/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaFlatMapStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaFlatMapStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaFlatMapStep.java
index 3a0028c..dd8da4f 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaFlatMapStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/map/LambdaFlatMapStep.java
@@ -38,6 +38,10 @@ public final class LambdaFlatMapStep<S, E> extends FlatMapStep<S, E> implements
this.function = function;
}
+ public Function<Traverser<S>, Iterator<E>> getFunction() {
+ return function;
+ }
+
@Override
protected Iterator<E> flatMap(final Traverser.Admin<S> traverser) {
return this.function.apply(traverser);
http://git-wip-us.apache.org/repos/asf/tinkerpop/blob/c0a03ca0/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/LambdaSideEffectStep.java
----------------------------------------------------------------------
diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/LambdaSideEffectStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/LambdaSideEffectStep.java
index e92556a..e2a27d1 100644
--- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/LambdaSideEffectStep.java
+++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/LambdaSideEffectStep.java
@@ -37,6 +37,10 @@ public final class LambdaSideEffectStep<S> extends SideEffectStep<S> implements
this.consumer = consumer;
}
+ public Consumer<Traverser<S>> getConsumer() {
+ return consumer;
+ }
+
@Override
protected void sideEffect(final Traverser.Admin<S> traverser) {
this.consumer.accept(traverser);