| Modifier and Type | Method and Description |
|---|---|
TraverserSet<?> |
TraversalVertexProgramMessageCombiner.combine(TraverserSet<?> messageA,
TraverserSet<?> messageB) |
| Modifier and Type | Method and Description |
|---|---|
Optional<MessageCombiner<TraverserSet<?>>> |
TraversalVertexProgram.getMessageCombiner() |
| Modifier and Type | Method and Description |
|---|---|
TraverserSet<?> |
TraversalVertexProgramMessageCombiner.combine(TraverserSet<?> messageA,
TraverserSet<?> messageB) |
TraverserSet<?> |
TraversalVertexProgramMessageCombiner.combine(TraverserSet<?> messageA,
TraverserSet<?> messageB) |
| Modifier and Type | Method and Description |
|---|---|
void |
TraversalVertexProgram.execute(Vertex vertex,
Messenger<TraverserSet<?>> messenger,
Memory memory) |
static boolean |
TraverserExecutor.execute(Vertex vertex,
Messenger<TraverserSet<?>> messenger,
TraversalMatrix<?,?> traversalMatrix) |
| Modifier and Type | Method and Description |
|---|---|
default GraphTraversal<S,E> |
GraphTraversal.barrier(Consumer<TraverserSet<Object>> barrierConsumer) |
static <A> GraphTraversal<A,A> |
__.barrier(Consumer<TraverserSet<Object>> barrierConsumer) |
| Modifier and Type | Method and Description |
|---|---|
void |
SampleGlobalStep.barrierConsumer(TraverserSet<S> traverserSet) |
| Modifier and Type | Method and Description |
|---|---|
void |
LambdaCollectingBarrierStep.barrierConsumer(TraverserSet<S> traverserSet) |
void |
OrderGlobalStep.barrierConsumer(TraverserSet<S> traverserSet) |
| Constructor and Description |
|---|
LambdaCollectingBarrierStep(Traversal.Admin traversal,
Consumer<TraverserSet<S>> barrierConsumer,
int maxBarrierSize) |
| Modifier and Type | Method and Description |
|---|---|
void |
AggregateStep.barrierConsumer(TraverserSet<S> traverserSet) |
| Modifier and Type | Method and Description |
|---|---|
abstract void |
CollectingBarrierStep.barrierConsumer(TraverserSet<S> traverserSet) |
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.