Package org.apache.tinkerpop.gremlin.tinkergraph.services

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 a Service.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(TinkerGraph graph)

Method Summary

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 the Service.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(TinkerGraph graph)

Method Detail

getType

public Service.Type getType()

Description copied from interface: Service

Return the Service.Type of service call.

Specified by:

getType in interface Service<Vertex,Long>

describeParams

public Map describeParams()

Description copied from interface: Service.ServiceFactory

Return a description of any service call parameters.

Specified by:

describeParams in interface Service.ServiceFactory<Vertex,Long>

Overrides:

describeParams in class TinkerServiceRegistry.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 interface Service.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 interface Service.ServiceFactory<Vertex,Long>

Parameters:

isStart - true if the call is being used to start a traversal

params - 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.

Specified by:

execute in interface Service<Vertex,Long>

close

public void close()

Description copied from interface: Service

Services can implement cleanup/shutdown procedures here.

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Service<Vertex,Long>

Specified by:

close in interface Service.ServiceFactory<Vertex,Long>