Package org.apache.tinkerpop.gremlin.tinkergraph.services

Class TinkerServiceRegistry.LambdaStreamingService<I,R>

java.lang.Object

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

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

All Implemented Interfaces:

AutoCloseable, Service<I,R>

Enclosing class:

TinkerServiceRegistry

public static class TinkerServiceRegistry.LambdaStreamingService<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	Description
LambdaStreamingService(TinkerServiceRegistry.LambdaServiceFactory<I,R> factory, TriFunction<Service.ServiceCallContext,Traverser.Admin<I>,Map,Iterator<R>> lambda)

Method Summary

Modifier and Type	Method	Description
CloseableIterator<R>	execute(Service.ServiceCallContext ctx, Traverser.Admin<I> in, Map params)	Execute a Streaming service call with one upstream input.
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, getMaxBarrierSize, isBarrier, isStart, isStreaming

Constructor Details

LambdaStreamingService

public LambdaStreamingService(TinkerServiceRegistry.LambdaServiceFactory<I,R> factory,
 TriFunction<Service.ServiceCallContext,Traverser.Admin<I>,Map,Iterator<R>> lambda)

Method Details

getType

public Service.Type getType()

Description copied from interface: Service

Return the Service.Type of service call.

execute

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

Description copied from interface: Service

Execute a Streaming service call with one upstream input.