| Modifier and Type | Method and Description | 
|---|---|
protected CloseableIterator | 
CallStep.flatMap(Traverser.Admin<S> traverser)  | 
protected CloseableIterator | 
CallStep.flatMap(TraverserSet<S> traverserSet)  | 
protected CloseableIterator | 
CallStep.start()  | 
| Modifier and Type | Method and Description | 
|---|---|
default CloseableIterator<R> | 
Service.execute(Service.ServiceCallContext ctx,
       Map params)
Execute a Start service call. 
 | 
CloseableIterator<String> | 
Service.DirectoryService.execute(Service.ServiceCallContext ctx,
       Map params)
List or describe any registered callable services. 
 | 
CloseableIterator | 
ServiceRegistry.execute(Service.ServiceCallContext ctx,
       Map params)
Service.DirectoryService execution. | 
default CloseableIterator<R> | 
Service.execute(Service.ServiceCallContext ctx,
       Traverser.Admin<I> in,
       Map params)
Execute a Streaming service call with one upstream input. 
 | 
default CloseableIterator<R> | 
Service.execute(Service.ServiceCallContext ctx,
       TraverserSet<I> in,
       Map params)
Execute a Barrier service call with all upstream input. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
static class  | 
CloseableIterator.EmptyCloseableIterator<T>  | 
class  | 
DefaultCloseableIterator<T>
A default implementation of  
CloseableIterator that simply wraps an existing Iterator. | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> CloseableIterator<T> | 
CloseableIterator.of(Iterator<T> iterator)
Wraps an existing  
Iterator in a CloseableIterator. | 
| Modifier and Type | Method and Description | 
|---|---|
CloseableIterator<R> | 
TinkerTextSearchFactory.execute(Service.ServiceCallContext ctx,
       Map params)  | 
CloseableIterator<R> | 
TinkerServiceRegistry.LambdaStartService.execute(Service.ServiceCallContext ctx,
       Map params)  | 
CloseableIterator<R> | 
TinkerServiceRegistry.LambdaStreamingService.execute(Service.ServiceCallContext ctx,
       Traverser.Admin<I> in,
       Map params)  | 
CloseableIterator<Long> | 
TinkerDegreeCentralityFactory.execute(Service.ServiceCallContext ctx,
       Traverser.Admin<Vertex> in,
       Map params)  | 
CloseableIterator<R> | 
TinkerServiceRegistry.LambdaBarrierService.execute(Service.ServiceCallContext ctx,
       TraverserSet<I> in,
       Map params)  | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
TinkerGraphIterator<E>
Wrapper on top of Iterator representing a closable resource to the underlying storage. 
 | 
Copyright © 2013–2022 Apache Software Foundation. All rights reserved.