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 |
OrderGlobalStep.barrierConsumer(TraverserSet<S> traverserSet) |
void |
LambdaCollectingBarrierStep.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–2016 Apache Software Foundation. All rights reserved.