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–2018 Apache Software Foundation. All rights reserved.