com.graphdbapi.parkit.vector

Class AbstractContext<SOURCE,TARGET,INPUT>

java.lang.Object

com.graphdbapi.parkit.vector.AbstractContext<SOURCE,TARGET,INPUT>

All Implemented Interfaces:

ContextParam<INPUT>, VertexCompute<SOURCE,TARGET>

public abstract class AbstractContext<SOURCE,TARGET,INPUT>
extends java.lang.Object
implements ContextParam<INPUT>, VertexCompute<SOURCE,TARGET>

抽象向量类 SOURCE(Long, Vertex) 起始点点类型 TARGET(Long, Vertex) 终止点点类型 INPUT(Long, Vertex, String) 输入点类型

Field Summary

Fields

Modifier and Type	Field and Description
protected Graph	graph
protected GraphLogger	graphLogger

Constructor Summary

Constructors

Constructor and Description
AbstractContext(Graph graph, GraphLogger graphLogger, java.util.List<INPUT> sourceIds, Accumulator... accumulators)

Method Summary

Modifier and Type	Method and Description
AbstractContext<SOURCE,TARGET,INPUT>	distributed()
java.util.List<Accumulator>	getAccumulators() 获取累计器集合
ExtendParam	getParam() 获取拓展参数
java.util.List<INPUT>	getSource() 获取起始点集合
boolean	isDistributed() 是否为分布式模式
boolean	isParallel() 是否为多线程模式
AbstractContext<SOURCE,TARGET,INPUT>	parallel()
AbstractContext<SOURCE,TARGET,INPUT>	setDirection(Direction direction)
AbstractContext<SOURCE,TARGET,INPUT>	setEdgeCondition(com.graphdbapi.parkit.condition.ConditionOnVisit edgeCondition)
AbstractContext<SOURCE,TARGET,INPUT>	setEdgeLimit(int edgeLimit)
AbstractContext<SOURCE,TARGET,INPUT>	setEdgeTypes(java.util.Set<java.lang.Integer> edgeTypes)
AbstractContext<SOURCE,TARGET,INPUT>	setIncludeProps(boolean includeProps)
AbstractContext<SOURCE,TARGET,INPUT>	setNeighborLimit(int neighborLimit)
AbstractContext<SOURCE,TARGET,INPUT>	setSourceCondition(com.graphdbapi.parkit.condition.ConditionOnVisit sourceCondition)
AbstractContext<SOURCE,TARGET,INPUT>	setSourceTypes(java.util.Set<java.lang.Integer> sourceTypes)
AbstractContext<SOURCE,TARGET,INPUT>	setStructure(java.lang.String structure)
AbstractContext<SOURCE,TARGET,INPUT>	setTargetCondition(com.graphdbapi.parkit.condition.ConditionOnVisit targetCondition)
AbstractContext<SOURCE,TARGET,INPUT>	setTargetTypes(java.util.Set<java.lang.Integer> targetTypes)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface com.graphdbapi.parkit.vector.VertexCompute

expand, scan, varLengthExpand, varLengthExpandCount

Field Detail

graph

protected final Graph graph

graphLogger

protected final GraphLogger graphLogger

Constructor Detail

AbstractContext

public AbstractContext(Graph graph,
                       GraphLogger graphLogger,
                       java.util.List<INPUT> sourceIds,
                       Accumulator... accumulators)

Parameters:

graph - 图对象

graphLogger - 图日志

sourceIds - sourceIds 可以传入点列表，还可以传入类型

accumulators - 累积器

Method Detail

getSource

public java.util.List<INPUT> getSource()

Description copied from interface: ContextParam

获取起始点集合

Specified by:

getSource in interface ContextParam<INPUT>

Returns:

起始点集合

getParam

public ExtendParam getParam()

Description copied from interface: ContextParam

获取拓展参数

Specified by:

getParam in interface ContextParam<INPUT>

Returns:

拓展参数

getAccumulators

public java.util.List<Accumulator> getAccumulators()

Description copied from interface: ContextParam

获取累计器集合

Specified by:

getAccumulators in interface ContextParam<INPUT>

Returns:

累计器集合

isDistributed

public boolean isDistributed()

Description copied from interface: ContextParam

是否为分布式模式

Specified by:

isDistributed in interface ContextParam<INPUT>

Returns:

是否为分布式模式

isParallel

public boolean isParallel()

Description copied from interface: ContextParam

是否为多线程模式

Specified by:

isParallel in interface ContextParam<INPUT>

Returns:

是否为多线程模式

setDirection

public AbstractContext<SOURCE,TARGET,INPUT> setDirection(Direction direction)

setSourceTypes

public AbstractContext<SOURCE,TARGET,INPUT> setSourceTypes(java.util.Set<java.lang.Integer> sourceTypes)

setEdgeTypes

public AbstractContext<SOURCE,TARGET,INPUT> setEdgeTypes(java.util.Set<java.lang.Integer> edgeTypes)

setTargetTypes

public AbstractContext<SOURCE,TARGET,INPUT> setTargetTypes(java.util.Set<java.lang.Integer> targetTypes)

setSourceCondition

public AbstractContext<SOURCE,TARGET,INPUT> setSourceCondition(com.graphdbapi.parkit.condition.ConditionOnVisit sourceCondition)

setEdgeCondition

public AbstractContext<SOURCE,TARGET,INPUT> setEdgeCondition(com.graphdbapi.parkit.condition.ConditionOnVisit edgeCondition)

setTargetCondition

public AbstractContext<SOURCE,TARGET,INPUT> setTargetCondition(com.graphdbapi.parkit.condition.ConditionOnVisit targetCondition)

setIncludeProps

public AbstractContext<SOURCE,TARGET,INPUT> setIncludeProps(boolean includeProps)

setNeighborLimit

public AbstractContext<SOURCE,TARGET,INPUT> setNeighborLimit(int neighborLimit)

setEdgeLimit

public AbstractContext<SOURCE,TARGET,INPUT> setEdgeLimit(int edgeLimit)

setStructure

public AbstractContext<SOURCE,TARGET,INPUT> setStructure(java.lang.String structure)

distributed

public AbstractContext<SOURCE,TARGET,INPUT> distributed()

parallel

public AbstractContext<SOURCE,TARGET,INPUT> parallel()