Package org.umlg.sqlg.services

Class SqlgServiceRegistry.LambdaServiceFactory<I,R>

java.lang.Object

org.umlg.sqlg.services.SqlgServiceRegistry.SqlgServiceFactory<I,R>

org.umlg.sqlg.services.SqlgServiceRegistry.LambdaServiceFactory<I,R>

All Implemented Interfaces:

AutoCloseable, org.apache.tinkerpop.gremlin.structure.service.Service.ServiceFactory<I,R>

Enclosing class:

SqlgServiceRegistry

public static class SqlgServiceRegistry.LambdaServiceFactory<I,R>
extends SqlgServiceRegistry.SqlgServiceFactory<I,R>

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	SqlgServiceRegistry.LambdaServiceFactory.Options

Field Summary

Fields inherited from class org.umlg.sqlg.services.SqlgServiceRegistry.SqlgServiceFactory

describeParams, graph, name, requirements

Constructor Summary

Constructors

Constructor	Description
LambdaServiceFactory(SqlgGraph graph, String name)

Method Summary

Modifier and Type	Method	Description
SqlgServiceRegistry.LambdaBarrierService	addBarrierLambda(org.apache.tinkerpop.gremlin.util.function.TriFunction<org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext,org.apache.tinkerpop.gremlin.process.traversal.traverser.util.TraverserSet<I>,Map,Iterator<R>> lambda)
SqlgServiceRegistry.LambdaBarrierService	addBarrierLambda(org.apache.tinkerpop.gremlin.util.function.TriFunction<org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext,org.apache.tinkerpop.gremlin.process.traversal.traverser.util.TraverserSet<I>,Map,Iterator<R>> lambda, int maxChunkSize)
SqlgServiceRegistry.LambdaServiceFactory	addDescribeParams(Map describeParams)
SqlgServiceRegistry.LambdaStartService	addStartLambda(BiFunction<org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext,Map,Iterator<R>> lambda)
SqlgServiceRegistry.LambdaStreamingService	addStreamingLambda(org.apache.tinkerpop.gremlin.util.function.TriFunction<org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext,org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<I>,Map,Iterator<R>> lambda)
org.apache.tinkerpop.gremlin.structure.service.Service<I,R>	createService(boolean isStart, Map params)
Set<org.apache.tinkerpop.gremlin.structure.service.Service.Type>	getSupportedTypes()

Methods inherited from class org.umlg.sqlg.services.SqlgServiceRegistry.SqlgServiceFactory

addRequirements, describeParams, getName, 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.ServiceFactory

close, getRequirementsByType

Constructor Details

LambdaServiceFactory

public LambdaServiceFactory(SqlgGraph graph,
 String name)

Method Details

getSupportedTypes

public Set<org.apache.tinkerpop.gremlin.structure.service.Service.Type> getSupportedTypes()

addDescribeParams

public SqlgServiceRegistry.LambdaServiceFactory addDescribeParams(Map describeParams)

Overrides:

addDescribeParams in class SqlgServiceRegistry.SqlgServiceFactory<I,R>

addStartLambda

public SqlgServiceRegistry.LambdaStartService addStartLambda(BiFunction<org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext,Map,Iterator<R>> lambda)

addStreamingLambda

public SqlgServiceRegistry.LambdaStreamingService addStreamingLambda(org.apache.tinkerpop.gremlin.util.function.TriFunction<org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext,org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<I>,Map,Iterator<R>> lambda)

addBarrierLambda

public SqlgServiceRegistry.LambdaBarrierService addBarrierLambda(org.apache.tinkerpop.gremlin.util.function.TriFunction<org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext,org.apache.tinkerpop.gremlin.process.traversal.traverser.util.TraverserSet<I>,Map,Iterator<R>> lambda)

addBarrierLambda

public SqlgServiceRegistry.LambdaBarrierService addBarrierLambda(org.apache.tinkerpop.gremlin.util.function.TriFunction<org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext,org.apache.tinkerpop.gremlin.process.traversal.traverser.util.TraverserSet<I>,Map,Iterator<R>> lambda,
 int maxChunkSize)

createService

public org.apache.tinkerpop.gremlin.structure.service.Service<I,R> createService(boolean isStart,
 Map params)