Class TinkerDegreeCentralityFactory
- java.lang.Object
-
- org.apache.tinkerpop.gremlin.tinkergraph.services.TinkerServiceRegistry.TinkerServiceFactory<Vertex,Long>
-
- org.apache.tinkerpop.gremlin.tinkergraph.services.TinkerDegreeCentralityFactory
-
- All Implemented Interfaces:
AutoCloseable
,Service<Vertex,Long>
,Service.ServiceFactory<Vertex,Long>
public class TinkerDegreeCentralityFactory extends TinkerServiceRegistry.TinkerServiceFactory<Vertex,Long> implements Service<Vertex,Long>
Count the IN/OUT/BOTH edges for a set of vertices. Demonstrates aService.Type.Streaming
service.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
TinkerDegreeCentralityFactory.Params
-
Nested classes/interfaces inherited from interface org.apache.tinkerpop.gremlin.structure.service.Service
Service.DirectoryService<I>, Service.Exceptions, Service.ServiceCallContext, Service.ServiceFactory<I,R>, Service.Type
-
-
Field Summary
Fields Modifier and Type Field Description static String
NAME
-
Fields inherited from class org.apache.tinkerpop.gremlin.tinkergraph.services.TinkerServiceRegistry.TinkerServiceFactory
describeParams, graph, name, requirements
-
-
Constructor Summary
Constructors Constructor Description TinkerDegreeCentralityFactory(AbstractTinkerGraph graph)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
Services can implement cleanup/shutdown procedures here.Service<Vertex,Long>
createService(boolean isStart, Map params)
Create a Service call instance.Map
describeParams()
Return a description of any service call parameters.CloseableIterator<Long>
execute(Service.ServiceCallContext ctx, Traverser.Admin<Vertex> in, Map params)
Execute a Streaming service call with one upstream input.Set<Service.Type>
getSupportedTypes()
Get the execution modes that it supports.Service.Type
getType()
Return theService.Type
of service call.-
Methods inherited from class org.apache.tinkerpop.gremlin.tinkergraph.services.TinkerServiceRegistry.TinkerServiceFactory
addDescribeParams, addRequirements, 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
execute, execute, getMaxBarrierSize, getRequirements, isBarrier, isStart, isStreaming
-
Methods inherited from interface org.apache.tinkerpop.gremlin.structure.service.Service.ServiceFactory
getRequirementsByType
-
-
-
-
Field Detail
-
NAME
public static final String NAME
- See Also:
- Constant Field Values
-
-
Constructor Detail
-
TinkerDegreeCentralityFactory
public TinkerDegreeCentralityFactory(AbstractTinkerGraph graph)
-
-
Method Detail
-
getType
public Service.Type getType()
Description copied from interface:Service
Return theService.Type
of service call.
-
describeParams
public Map describeParams()
Description copied from interface:Service.ServiceFactory
Return a description of any service call parameters.- Specified by:
describeParams
in interfaceService.ServiceFactory<Vertex,Long>
- Overrides:
describeParams
in classTinkerServiceRegistry.TinkerServiceFactory<Vertex,Long>
-
getSupportedTypes
public Set<Service.Type> getSupportedTypes()
Description copied from interface:Service.ServiceFactory
Get the execution modes that it supports.- Specified by:
getSupportedTypes
in interfaceService.ServiceFactory<Vertex,Long>
-
createService
public Service<Vertex,Long> createService(boolean isStart, Map params)
Description copied from interface:Service.ServiceFactory
Create a Service call instance.- Specified by:
createService
in interfaceService.ServiceFactory<Vertex,Long>
- Parameters:
isStart
- true if the call is being used to start a traversalparams
- the static params provided to service call (if any)- Returns:
- the service call instance
-
execute
public CloseableIterator<Long> execute(Service.ServiceCallContext ctx, Traverser.Admin<Vertex> in, Map params)
Description copied from interface:Service
Execute a Streaming service call with one upstream input.
-
-