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.