Modifier and Type | Method and Description |
---|---|
default CredentialTraversal<S,E> |
CredentialTraversal.barrier(Consumer<TraverserSet<Object>> barrierConsumer) |
static <A> CredentialTraversal<A,A> |
__.barrier(Consumer<TraverserSet<Object>> barrierConsumer) |
Modifier and Type | Method and Description |
---|---|
TraverserSet<Object> |
TraversalVertexProgramMessageCombiner.combine(TraverserSet<Object> messageA,
TraverserSet<Object> messageB) |
static <R> TraverserSet<R> |
TraversalVertexProgram.loadHaltedTraversers(org.apache.commons.configuration2.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(org.apache.commons.configuration2.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 Supplier<TraverserSet<S>> |
Traversal.Admin.getTraverserSetSupplier()
Gets a generator that creates new
TraverserSet instances for steps in the traversal. |
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> |
RangeGlobalStep.nextBarrier() |
TraverserSet<S> |
TailGlobalStep.nextBarrier() |
Modifier and Type | Method and Description |
---|---|
MemoryComputeKey<TraverserSet<S>> |
RangeGlobalStep.getMemoryComputeKey() |
MemoryComputeKey<TraverserSet<S>> |
TailGlobalStep.getMemoryComputeKey() |
Modifier and Type | Method and Description |
---|---|
void |
RangeGlobalStep.addBarrier(TraverserSet<S> barrier) |
void |
TailGlobalStep.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 |
OrderGlobalStep.barrierConsumer(TraverserSet<S> traverserSet) |
void |
LambdaCollectingBarrierStep.barrierConsumer(TraverserSet<S> traverserSet) |
protected CloseableIterator |
CallStep.flatMap(TraverserSet<S> traverserSet) |
protected Map |
CallStep.getMergedParams(TraverserSet<S> traverserSet) |
Constructor and Description |
---|
LambdaCollectingBarrierStep(Traversal.Admin traversal,
Consumer<TraverserSet<S>> barrierConsumer,
int maxBarrierSize) |
Modifier and Type | Method and Description |
---|---|
TraverserSet<S> |
AggregateGlobalStep.nextBarrier() |
Modifier and Type | Method and Description |
---|---|
void |
AggregateGlobalStep.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) |
Constructor and Description |
---|
ExpandableStepIterator(Step<S,?> hostStep,
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. |
Modifier and Type | Method and Description |
---|---|
default CloseableIterator<R> |
Service.execute(Service.ServiceCallContext ctx,
TraverserSet<I> in,
Map params)
Execute a Barrier service call with all upstream input.
|
Modifier and Type | Method and Description |
---|---|
CloseableIterator<R> |
TinkerServiceRegistry.LambdaBarrierService.execute(Service.ServiceCallContext ctx,
TraverserSet<I> in,
Map params) |
Modifier and Type | Method and Description |
---|---|
TinkerServiceRegistry.LambdaBarrierService |
TinkerServiceRegistry.LambdaServiceFactory.addBarrierLambda(TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda) |
TinkerServiceRegistry.LambdaBarrierService |
TinkerServiceRegistry.LambdaServiceFactory.addBarrierLambda(TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda,
int maxChunkSize) |
Constructor and Description |
---|
LambdaBarrierService(TinkerServiceRegistry.LambdaServiceFactory<I,R> factory,
TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda) |
LambdaBarrierService(TinkerServiceRegistry.LambdaServiceFactory<I,R> factory,
TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda,
int maxChunkSize) |
Modifier and Type | Method and Description |
---|---|
TraverserSet<S> |
TraverserSetSupplier.get() |
Copyright © 2013–2022 Apache Software Foundation. All rights reserved.