| Modifier and Type | Method and Description | 
|---|---|
TraverserSet<Object> | 
TraversalVertexProgramMessageCombiner.combine(TraverserSet<Object> messageA,
       TraverserSet<Object> messageB)  | 
static <R> TraverserSet<R> | 
TraversalVertexProgram.loadHaltedTraversers(Configuration configuration)  | 
| Modifier and Type | Method and Description | 
|---|---|
Optional<MessageCombiner<TraverserSet<Object>>> | 
TraversalVertexProgram.getMessageCombiner()  | 
| Modifier and Type | Method and Description | 
|---|---|
TraverserSet<Object> | 
TraversalVertexProgramMessageCombiner.combine(TraverserSet<Object> messageA,
       TraverserSet<Object> messageB)  | 
TraverserSet<Object> | 
TraversalVertexProgramMessageCombiner.combine(TraverserSet<Object> messageA,
       TraverserSet<Object> messageB)  | 
TraversalVertexProgram.Builder | 
TraversalVertexProgram.Builder.haltedTraversers(TraverserSet<Object> haltedTraversers)  | 
static <R> void | 
TraversalVertexProgram.storeHaltedTraversers(Configuration configuration,
                     TraverserSet<R> haltedTraversers)  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TraversalVertexProgram.execute(Vertex vertex,
       Messenger<TraverserSet<Object>> messenger,
       Memory memory)  | 
| Modifier and Type | Method and Description | 
|---|---|
default GraphTraversal<S,E> | 
GraphTraversal.barrier(Consumer<TraverserSet<Object>> barrierConsumer)
Turns the lazy traversal pipeline into a bulk-synchronous pipeline which basically iterates that traversal to
 the size of the barrier. 
 | 
static <A> GraphTraversal<A,A> | 
__.barrier(Consumer<TraverserSet<Object>> barrierConsumer)  | 
| Modifier and Type | Method and Description | 
|---|---|
TraverserSet<S> | 
RangeGlobalStep.RangeBiOperator.apply(TraverserSet<S> mutatingSeed,
     TraverserSet<S> set)  | 
TraverserSet<S> | 
TailGlobalStep.nextBarrier()  | 
TraverserSet<S> | 
RangeGlobalStep.nextBarrier()  | 
| Modifier and Type | Method and Description | 
|---|---|
MemoryComputeKey<TraverserSet<S>> | 
TailGlobalStep.getMemoryComputeKey()  | 
MemoryComputeKey<TraverserSet<S>> | 
RangeGlobalStep.getMemoryComputeKey()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
TailGlobalStep.addBarrier(TraverserSet<S> barrier)  | 
void | 
RangeGlobalStep.addBarrier(TraverserSet<S> barrier)  | 
TraverserSet<S> | 
RangeGlobalStep.RangeBiOperator.apply(TraverserSet<S> mutatingSeed,
     TraverserSet<S> set)  | 
TraverserSet<S> | 
RangeGlobalStep.RangeBiOperator.apply(TraverserSet<S> mutatingSeed,
     TraverserSet<S> set)  | 
void | 
SampleGlobalStep.barrierConsumer(TraverserSet<S> traverserSet)  | 
| Modifier and Type | Method and Description | 
|---|---|
TraverserSet<S> | 
OrderGlobalStep.OrderBiOperator.apply(TraverserSet<S> setA,
     TraverserSet<S> setB)  | 
TraverserSet<S> | 
NoOpBarrierStep.nextBarrier()  | 
| Modifier and Type | Method and Description | 
|---|---|
Consumer<TraverserSet<S>> | 
LambdaCollectingBarrierStep.getBarrierConsumer()  | 
MemoryComputeKey<TraverserSet<S>> | 
OrderGlobalStep.getMemoryComputeKey()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
NoOpBarrierStep.addBarrier(TraverserSet<S> barrier)  | 
TraverserSet<S> | 
OrderGlobalStep.OrderBiOperator.apply(TraverserSet<S> setA,
     TraverserSet<S> setB)  | 
TraverserSet<S> | 
OrderGlobalStep.OrderBiOperator.apply(TraverserSet<S> setA,
     TraverserSet<S> setB)  | 
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 | 
|---|---|
TraverserSet<S> | 
AggregateStep.nextBarrier()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
AggregateStep.addBarrier(TraverserSet<S> barrier)  | 
| Modifier and Type | Field and Description | 
|---|---|
protected TraverserSet<S> | 
CollectingBarrierStep.traverserSet  | 
| Modifier and Type | Method and Description | 
|---|---|
TraverserSet<S> | 
CollectingBarrierStep.nextBarrier()  | 
| Modifier and Type | Method and Description | 
|---|---|
MemoryComputeKey<TraverserSet<S>> | 
CollectingBarrierStep.getMemoryComputeKey()  | 
| Modifier and Type | Method and Description | 
|---|---|
void | 
CollectingBarrierStep.addBarrier(TraverserSet<S> barrier)  | 
abstract void | 
CollectingBarrierStep.barrierConsumer(TraverserSet<S> traverserSet)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
IndexedTraverserSet<S,I>
A  
TraverserSet that has an index back to the object in the Traverser. | 
static class  | 
IndexedTraverserSet.VertexIndexedTraverserSet
An  
IndexedTraverserSet that indexes based on a Vertex traverser. | 
Copyright © 2013–2020 Apache Software Foundation. All rights reserved.