public static class TinkerServiceRegistry.LambdaServiceFactory<I,R> extends TinkerServiceRegistry.TinkerServiceFactory<I,R>
Modifier and Type | Class and Description |
---|---|
static interface |
TinkerServiceRegistry.LambdaServiceFactory.Options |
describeParams, graph, name, requirements
Constructor and Description |
---|
LambdaServiceFactory(TinkerGraph graph,
String name) |
Modifier and Type | Method and Description |
---|---|
TinkerServiceRegistry.LambdaBarrierService |
addBarrierLambda(TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda) |
TinkerServiceRegistry.LambdaBarrierService |
addBarrierLambda(TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda,
int maxChunkSize) |
TinkerServiceRegistry.LambdaServiceFactory |
addDescribeParams(Map describeParams) |
TinkerServiceRegistry.LambdaStartService |
addStartLambda(BiFunction<Service.ServiceCallContext,Map,Iterator<R>> lambda) |
TinkerServiceRegistry.LambdaStreamingService |
addStreamingLambda(TriFunction<Service.ServiceCallContext,Traverser.Admin<I>,Map,Iterator<R>> lambda) |
Service<I,R> |
createService(boolean isStart,
Map params)
Create a Service call instance.
|
Set<Service.Type> |
getSupportedTypes()
Get the execution modes that it supports.
|
addRequirements, describeParams, getName, getRequirements
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, getRequirementsByType
public LambdaServiceFactory(TinkerGraph graph, String name)
public Set<Service.Type> getSupportedTypes()
Service.ServiceFactory
public TinkerServiceRegistry.LambdaServiceFactory addDescribeParams(Map describeParams)
addDescribeParams
in class TinkerServiceRegistry.TinkerServiceFactory<I,R>
public TinkerServiceRegistry.LambdaStartService addStartLambda(BiFunction<Service.ServiceCallContext,Map,Iterator<R>> lambda)
public TinkerServiceRegistry.LambdaStreamingService addStreamingLambda(TriFunction<Service.ServiceCallContext,Traverser.Admin<I>,Map,Iterator<R>> lambda)
public TinkerServiceRegistry.LambdaBarrierService addBarrierLambda(TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda)
public TinkerServiceRegistry.LambdaBarrierService addBarrierLambda(TriFunction<Service.ServiceCallContext,TraverserSet<I>,Map,Iterator<R>> lambda, int maxChunkSize)
public Service<I,R> createService(boolean isStart, Map params)
Service.ServiceFactory
isStart
- true if the call is being used to start a traversalparams
- the static params provided to service call (if any)Copyright © 2013–2022 Apache Software Foundation. All rights reserved.