Package org.umlg.sqlg.services

Class SqlgServiceRegistry.LambdaStreamingService<I,R>

java.lang.Object
org.umlg.sqlg.services.SqlgServiceRegistry.SqlgService<I,R>
org.umlg.sqlg.services.SqlgServiceRegistry.LambdaStreamingService<I,R>
All Implemented Interfaces:
AutoCloseable, org.apache.tinkerpop.gremlin.structure.service.Service<I,R>
Enclosing class:
SqlgServiceRegistry
public static class SqlgServiceRegistry.LambdaStreamingService<I,R> extends SqlgServiceRegistry.SqlgService<I,R>

  • Nested Class Summary

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

    org.apache.tinkerpop.gremlin.structure.service.Service.DirectoryService<I extends Object>, org.apache.tinkerpop.gremlin.structure.service.Service.Exceptions, org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext, org.apache.tinkerpop.gremlin.structure.service.Service.ServiceFactory<I extends Object,R extends Object>, org.apache.tinkerpop.gremlin.structure.service.Service.Type

  • Field Summary

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

    serviceFactory

  • Constructor Summary

    Constructors
    Constructor
    Description
    LambdaStreamingService(SqlgServiceRegistry.LambdaServiceFactory<I,R> factory, 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)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.tinkerpop.gremlin.structure.util.CloseableIterator<R>
    execute(org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext ctx, org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<I> in, Map params)
     
    org.apache.tinkerpop.gremlin.structure.service.Service.Type
    getType()
     

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

    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(SqlgServiceRegistry.LambdaServiceFactory<I,R> factory, 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)

  • Method Details

    • getType

      public org.apache.tinkerpop.gremlin.structure.service.Service.Type getType()

    • execute

      public org.apache.tinkerpop.gremlin.structure.util.CloseableIterator<R> execute(org.apache.tinkerpop.gremlin.structure.service.Service.ServiceCallContext ctx, org.apache.tinkerpop.gremlin.process.traversal.Traverser.Admin<I> in, Map params)