This is an automated email from the ASF dual-hosted git repository. colegreer pushed a commit to branch sideEffectBarrier in repository https://gitbox.apache.org/repos/asf/tinkerpop.git
commit 83921ba6a6717e549251c3c0a9690854c6d52dca Author: Cole-Greer <[email protected]> AuthorDate: Sat Oct 25 23:14:05 2025 -0700 add clone() override --- .../process/traversal/step/sideEffect/SideEffectBarrierStep.java | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/SideEffectBarrierStep.java b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/SideEffectBarrierStep.java index 4a74994e2a..dc50a0e081 100644 --- a/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/SideEffectBarrierStep.java +++ b/gremlin-core/src/main/java/org/apache/tinkerpop/gremlin/process/traversal/step/sideEffect/SideEffectBarrierStep.java @@ -58,7 +58,6 @@ public abstract class SideEffectBarrierStep<S> extends AbstractStep<S, S> implem // when barrier is reloaded, the traversers should be at the next step this.barrier.add(traverser); } - } @Override @@ -93,4 +92,11 @@ public abstract class SideEffectBarrierStep<S> extends AbstractStep<S, S> implem super.reset(); this.barrier.clear(); } + + @Override + public SideEffectBarrierStep<S> clone() { + final SideEffectBarrierStep<S> clone = (SideEffectBarrierStep<S>) super.clone(); + clone.barrier = (TraverserSet<S>) this.traversal.getTraverserSetSupplier().get(); + return clone; + } }
