org.apache.tinkerpop.gremlin.tinkergraph.services

Class TinkerServiceRegistry.LambdaBarrierService<I,R>

java.lang.Object

org.apache.tinkerpop.gremlin.tinkergraph.services.TinkerServiceRegistry.TinkerService<I,R>

org.apache.tinkerpop.gremlin.tinkergraph.services.TinkerServiceRegistry.LambdaBarrierService<I,R>

All Implemented Interfaces:

AutoCloseable, Service<I,R>

Enclosing class:

TinkerServiceRegistry

public static class TinkerServiceRegistry.LambdaBarrierService<I,R>
extends TinkerServiceRegistry.TinkerService<I,R>

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.tinkerpop.gremlin.structure.service.Service

Service.DirectoryService<I>, Service.Exceptions, Service.ServiceCallContext, Service.ServiceFactory<I,R>, Service.Type

Field Summary

Fields inherited from class org.apache.tinkerpop.gremlin.tinkergraph.services.TinkerServiceRegistry.TinkerService

serviceFactory

Constructor Summary

Constructors

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)

Method Summary

Modifier and Type	Method and Description
TinkerServiceRegistry.LambdaBarrierService	clone(int maxChunkSize)
CloseableIterator<R>	execute(Service.ServiceCallContext ctx, TraverserSet<I> in, Map params) Execute a Barrier service call with all upstream input.
int	getMaxBarrierSize() Return the max barrier size.
Service.Type	getType() Return the Service.Type of service call.

Methods inherited from class org.apache.tinkerpop.gremlin.tinkergraph.services.TinkerServiceRegistry.TinkerService

addRequirements, getRequirements

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.tinkerpop.gremlin.structure.service.Service

close, execute, execute, isBarrier, isStart, isStreaming

Constructor Detail

LambdaBarrierService

public LambdaBarrierService(TinkerServiceRegistry.LambdaServiceFactory<I,R> factory,
                            TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda)

LambdaBarrierService

public LambdaBarrierService(TinkerServiceRegistry.LambdaServiceFactory<I,R> factory,
                            TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda,
                            int maxChunkSize)

Method Detail

clone

public TinkerServiceRegistry.LambdaBarrierService clone(int maxChunkSize)

getType

public Service.Type getType()

Description copied from interface: Service

Return the Service.Type of service call.

getMaxBarrierSize

public int getMaxBarrierSize()

Description copied from interface: Service

Return the max barrier size. Default is all upstream solutions.

execute

public CloseableIterator<R> execute(Service.ServiceCallContext ctx,
                                    TraverserSet<I> in,
                                    Map params)

Description copied from interface: Service

Execute a Barrier service call with all upstream input.