com.graphdbapi.parkit.util

Class ParUtil

java.lang.Object

com.graphdbapi.parkit.util.ParUtil

public class ParUtil
extends java.lang.Object

PAR 相关工具类

Constructor Summary

Constructors

Constructor and Description
ParUtil()

Method Summary

Modifier and Type	Method and Description
static boolean	checkId(Graph graph, long vertexId, java.util.function.Predicate<Element> vertexCondition) 点检查，包含属性过滤以及停止检查
static boolean	checkId(Graph graph, long vertexId, java.util.Set<java.lang.Integer> vertexTypes) 点检查，包含类型过滤以及停止检查
static boolean	checkId(Graph graph, long vertexId, java.util.Set<java.lang.Integer> vertexTypes, java.util.function.Predicate<Element> vertexCondition) 点检查，包含属性过滤和类型过滤以及停止检查
static boolean	checkLocal(Graph graph, long vertexId) 检查点是否在对应机器上以及停止检查
static boolean	checkVertex(Graph graph, Vertex vertex, java.util.function.Predicate<Element> vertexCondition) 点检查，包含属性过滤以及停止检查
static boolean	checkVertex(Graph graph, Vertex vertex, java.util.Set<java.lang.Integer> vertexTypes) 点检查，包含类型过滤以及停止检查
static boolean	checkVertex(Graph graph, Vertex vertex, java.util.Set<java.lang.Integer> vertexTypes, java.util.function.Predicate<Element> vertexCondition) 点检查，包含属性过滤和类型过滤以及停止检查
static Direction	convertDirection(java.lang.String direction) 方向转换
static java.util.Set<java.lang.Integer>	convertEdgeTypeName(Graph graph, java.util.Set<java.lang.String> edgeTypeNames) 转换边类型名到边类型index
static java.util.Set<java.lang.Integer>	convertEdgeTypeName(Graph graph, java.lang.String... edgeTypeNames) 转换边类型名到边类型index
static java.util.Set<java.lang.Integer>	convertVertexTypeName(Graph graph, java.util.Set<java.lang.String> vertexTypeNames) 转换点类型名到点类型index
static java.util.Set<java.lang.Integer>	convertVertexTypeName(Graph graph, java.lang.String... vertexTypeNames) 转换点类型名到点类型index
static java.util.Map<java.lang.String,java.lang.Object>	extendCompute(Graph graph, long vertexId, ExtendParam param, java.util.List<java.lang.String> rules) 单点扩展计算
static java.util.Map<java.lang.String,java.lang.Object>	extendCompute(Graph graph, long vertexId, ExtendParam param, java.lang.String rule) 单点扩展计算
static java.util.Map<java.lang.String,java.lang.Object>	extendCompute(Graph graph, long vertexId, java.lang.String structure, java.util.List<java.lang.String> rules) 单点扩展计算
static java.util.Map<java.lang.String,java.lang.Object>	extendCompute(Graph graph, long vertexId, java.lang.String structure, java.lang.String rule) 单点扩展计算
static java.util.Map<java.lang.String,java.lang.Object>	extendCompute(Graph graph, long vertexId, java.lang.String structure, java.lang.String filter, java.util.List<java.lang.String> rules) 单点扩展计算
static ResourceIterator<Edge>	extendEdge(Graph graph, long vertexId) 获取边迭代器
static void	extendEdge(Graph graph, long vertexId, com.graphdbapi.parkit.consumer.Consumer<Edge> consumer) 边迭代计算
static ResourceIterator<Edge>	extendEdge(Graph graph, long vertexId, ExtendParam param) 获取边迭代器
static void	extendEdge(Graph graph, long vertexId, ExtendParam param, com.graphdbapi.parkit.consumer.Consumer<Edge> consumer) 边迭代计算
static ResourceIterator<Edge>	extendEdge(Graph graph, long vertexId, java.lang.String structure) 获取边迭代器
static void	extendEdge(Graph graph, long vertexId, java.lang.String structure, com.graphdbapi.parkit.consumer.Consumer<Edge> consumer) 边迭代计算
static java.util.List<Edge>	extendEdgeList(Graph graph, long vertexId) 获取边列表
static java.util.List<Edge>	extendEdgeList(Graph graph, long vertexId, ExtendParam param) 获取边列表
static java.util.List<Edge>	extendEdgeList(Graph graph, long vertexId, java.lang.String structure) 获取边列表
static Edge	extendSingleEdge(Graph graph, long vertexId) 获取单条边
static Edge	extendSingleEdge(Graph graph, long vertexId, ExtendParam param) 获取单条边
static Edge	extendSingleEdge(Graph graph, long vertexId, java.lang.String structure) 获取单条边
static java.util.Map<java.lang.Long,java.util.List<java.lang.Object>>	getProperty(Graph graph, java.util.List<java.lang.Long> ids, java.lang.String... propertyNames) 批量获取点属性
static java.util.Map<java.lang.Long,java.lang.Object>	getProperty(Graph graph, java.util.List<java.lang.Long> ids, java.lang.String propertyName) 批量获取点属性
static long	getVertexCount(Graph graph, java.util.List<java.lang.Long> ids, java.util.function.Predicate<Element> vertexCondition) 获取点属性过滤后的点数
static long	getVertexCount(Graph graph, java.util.List<java.lang.Long> ids, java.util.Set<java.lang.Integer> vertexTypes) 获取点类型过滤后的点数
static long	getVertexCount(Graph graph, java.util.List<java.lang.Long> ids, java.util.Set<java.lang.Integer> vertexTypes, java.util.function.Predicate<Element> vertexCondition) 获取点类型属性过滤后的点数
static java.util.Set<java.lang.Long>	getVertexIds(Graph graph, java.util.function.Predicate<Element> vertexCondition) 通过属性过滤获取一批点id
static java.util.Set<java.lang.Long>	getVertexIds(Graph graph, java.util.Set<java.lang.Integer> vertexTypes) 通过类型过滤获取一批点id
static java.util.Set<java.lang.Long>	getVertexIds(Graph graph, java.util.Set<java.lang.Integer> vertexTypes, java.util.function.Predicate<Element> vertexCondition) 通过类型属性过滤获取一批点id
static java.util.Set<java.lang.Long>	getVertexIdsFast(Graph graph, java.util.function.Predicate<Element> vertexCondition) 通过属性过滤获取一批点id，多线程加速
static java.util.Set<java.lang.Long>	getVertexIdsFast(Graph graph, java.util.Set<java.lang.Integer> vertexTypes) 通过类型过滤获取一批点id，多线程加速
static java.util.Set<java.lang.Long>	getVertexIdsFast(Graph graph, java.util.Set<java.lang.Integer> vertexTypes, java.util.function.Predicate<Element> vertexCondition) 通过类型属性过滤获取一批点id，多线程加速
static java.util.List<java.lang.Long>	getVertexList(Graph graph, java.util.List<java.lang.Long> ids, java.util.function.Predicate<Element> vertexCondition) 获取点属性过滤后的点列表
static java.util.List<java.lang.Long>	getVertexList(Graph graph, java.util.List<java.lang.Long> ids, java.util.Set<java.lang.Integer> vertexTypes) 获取点类型过滤后的点列表
static java.util.List<java.lang.Long>	getVertexList(Graph graph, java.util.List<java.lang.Long> ids, java.util.Set<java.lang.Integer> vertexTypes, java.util.function.Predicate<Element> vertexCondition) 获取点类型属性过滤后的点列表
static Direction	reverseDirection(Direction direction) 反转方向

Methods inherited from class java.lang.Object

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

Constructor Detail

ParUtil

public ParUtil()

Method Detail

checkId

public static boolean checkId(Graph graph,
                              long vertexId,
                              java.util.Set<java.lang.Integer> vertexTypes,
                              java.util.function.Predicate<Element> vertexCondition)

点检查，包含属性过滤和类型过滤以及停止检查

Parameters:

graph - 图对象

vertexId - 点id

vertexTypes - 点类型列表

vertexCondition - 点属性过滤

Returns:

是否合法

checkId

public static boolean checkId(Graph graph,
                              long vertexId,
                              java.util.Set<java.lang.Integer> vertexTypes)

点检查，包含类型过滤以及停止检查

Parameters:

graph - 图对象

vertexId - 点id

vertexTypes - 点类型列表

Returns:

是否合法

checkId

public static boolean checkId(Graph graph,
                              long vertexId,
                              java.util.function.Predicate<Element> vertexCondition)

点检查，包含属性过滤以及停止检查

Parameters:

graph - 图对象

vertexId - 点id

vertexCondition - 点属性过滤

Returns:

是否合法

checkVertex

public static boolean checkVertex(Graph graph,
                                  Vertex vertex,
                                  java.util.Set<java.lang.Integer> vertexTypes,
                                  java.util.function.Predicate<Element> vertexCondition)

点检查，包含属性过滤和类型过滤以及停止检查

Parameters:

graph - 图对象

vertex - 点对象

vertexTypes - 点类型列表

vertexCondition - 点属性过滤

Returns:

是否合法

checkVertex

public static boolean checkVertex(Graph graph,
                                  Vertex vertex,
                                  java.util.Set<java.lang.Integer> vertexTypes)

点检查，包含类型过滤以及停止检查

Parameters:

graph - 图对象

vertex - 点对象

vertexTypes - 点类型列表

Returns:

是否合法

checkVertex

public static boolean checkVertex(Graph graph,
                                  Vertex vertex,
                                  java.util.function.Predicate<Element> vertexCondition)

点检查，包含属性过滤以及停止检查

Parameters:

graph - 图对象

vertex - 点对象

vertexCondition - 点属性过滤

Returns:

是否合法

checkLocal

public static boolean checkLocal(Graph graph,
                                 long vertexId)

检查点是否在对应机器上以及停止检查

Parameters:

graph - 图对象

vertexId - 点id

Returns:

点是否在本机

extendEdge

public static ResourceIterator<Edge> extendEdge(Graph graph,
                                                long vertexId,
                                                ExtendParam param)

获取边迭代器

Parameters:

graph - 图对象

vertexId - 点id

param - 拓展参数

Returns:

边迭代器

extendEdge

public static ResourceIterator<Edge> extendEdge(Graph graph,
                                                long vertexId,
                                                java.lang.String structure)

获取边迭代器

Parameters:

graph - 图对象

vertexId - 点id

structure - 拓展结构

Returns:

边迭代器

extendEdge

public static ResourceIterator<Edge> extendEdge(Graph graph,
                                                long vertexId)

获取边迭代器

Parameters:

graph - 图对象

vertexId - 点id

Returns:

边迭代器

extendEdgeList

public static java.util.List<Edge> extendEdgeList(Graph graph,
                                                  long vertexId,
                                                  ExtendParam param)

获取边列表

Parameters:

graph - 图对象

vertexId - 点id

param - 拓展参数

Returns:

边列表

extendEdgeList

public static java.util.List<Edge> extendEdgeList(Graph graph,
                                                  long vertexId,
                                                  java.lang.String structure)

获取边列表

Parameters:

graph - 图对象

vertexId - 点id

structure - 拓展结构

Returns:

边列表

extendEdgeList

public static java.util.List<Edge> extendEdgeList(Graph graph,
                                                  long vertexId)

获取边列表

Parameters:

graph - 图对象

vertexId - 点id

Returns:

边列表

extendEdge

public static void extendEdge(Graph graph,
                              long vertexId,
                              ExtendParam param,
                              com.graphdbapi.parkit.consumer.Consumer<Edge> consumer)

边迭代计算

Parameters:

graph - 图对象

vertexId - 点id

param - 拓展参数

consumer - 计算逻辑

extendEdge

public static void extendEdge(Graph graph,
                              long vertexId,
                              java.lang.String structure,
                              com.graphdbapi.parkit.consumer.Consumer<Edge> consumer)

边迭代计算

Parameters:

graph - 图对象

vertexId - 点id

structure - 拓展结构

consumer - 计算逻辑

extendEdge

public static void extendEdge(Graph graph,
                              long vertexId,
                              com.graphdbapi.parkit.consumer.Consumer<Edge> consumer)

边迭代计算

Parameters:

graph - 图对象

vertexId - 点id

consumer - 计算逻辑

extendSingleEdge

public static Edge extendSingleEdge(Graph graph,
                                    long vertexId,
                                    ExtendParam param)

获取单条边

Parameters:

graph - 图对象

vertexId - 点id

param - 拓展参数

Returns:

边对象

extendSingleEdge

public static Edge extendSingleEdge(Graph graph,
                                    long vertexId,
                                    java.lang.String structure)

获取单条边

Parameters:

graph - 图对象

vertexId - 点id

structure - 拓展结构

Returns:

边对象

extendSingleEdge

public static Edge extendSingleEdge(Graph graph,
                                    long vertexId)

获取单条边

Parameters:

graph - 图对象

vertexId - 点id

Returns:

边对象

extendCompute

public static java.util.Map<java.lang.String,java.lang.Object> extendCompute(Graph graph,
                                                                             long vertexId,
                                                                             ExtendParam param,
                                                                             java.util.List<java.lang.String> rules)

单点扩展计算

Parameters:

graph - 图对象

vertexId - 点id

param - 拓展参数

rules - 计算逻辑

Returns:

结果

extendCompute

public static java.util.Map<java.lang.String,java.lang.Object> extendCompute(Graph graph,
                                                                             long vertexId,
                                                                             ExtendParam param,
                                                                             java.lang.String rule)

单点扩展计算

Parameters:

graph - 图对象

vertexId - 点id

param - 拓展参数

rule - 计算逻辑

Returns:

结果

extendCompute

public static java.util.Map<java.lang.String,java.lang.Object> extendCompute(Graph graph,
                                                                             long vertexId,
                                                                             java.lang.String structure,
                                                                             java.util.List<java.lang.String> rules)

单点扩展计算

Parameters:

graph - 图对象

vertexId - 点id

structure - 拓展结构

rules - 计算逻辑

Returns:

结果

extendCompute

public static java.util.Map<java.lang.String,java.lang.Object> extendCompute(Graph graph,
                                                                             long vertexId,
                                                                             java.lang.String structure,
                                                                             java.lang.String filter,
                                                                             java.util.List<java.lang.String> rules)

单点扩展计算

Parameters:

graph - 图对象

vertexId - 点id

structure - 拓展结构

filter - 过滤条件

rules - 计算逻辑

Returns:

结果

extendCompute

public static java.util.Map<java.lang.String,java.lang.Object> extendCompute(Graph graph,
                                                                             long vertexId,
                                                                             java.lang.String structure,
                                                                             java.lang.String rule)

单点扩展计算

Parameters:

graph - 图对象

vertexId - 点id

structure - 拓展结构

rule - 计算逻辑

Returns:

结果

getVertexCount

public static long getVertexCount(Graph graph,
                                  java.util.List<java.lang.Long> ids,
                                  java.util.Set<java.lang.Integer> vertexTypes,
                                  java.util.function.Predicate<Element> vertexCondition)

获取点类型属性过滤后的点数

Parameters:

graph - 图对象

ids - 点集合

vertexTypes - 点类型列表

vertexCondition - 点属性过滤

Returns:

符合要求的点数

getVertexCount

public static long getVertexCount(Graph graph,
                                  java.util.List<java.lang.Long> ids,
                                  java.util.Set<java.lang.Integer> vertexTypes)

获取点类型过滤后的点数

Parameters:

graph - 图对象

ids - 点集合

vertexTypes - 点类型列表

Returns:

符合要求的点数

getVertexCount

public static long getVertexCount(Graph graph,
                                  java.util.List<java.lang.Long> ids,
                                  java.util.function.Predicate<Element> vertexCondition)

获取点属性过滤后的点数

Parameters:

graph - 图对象

ids - 点集合

vertexCondition - 点属性过滤

Returns:

符合要求的点数

getVertexList

public static java.util.List<java.lang.Long> getVertexList(Graph graph,
                                                           java.util.List<java.lang.Long> ids,
                                                           java.util.Set<java.lang.Integer> vertexTypes,
                                                           java.util.function.Predicate<Element> vertexCondition)

获取点类型属性过滤后的点列表

Parameters:

graph - 图对象

ids - 点集合

vertexTypes - 点类型列表

vertexCondition - 点属性过滤

Returns:

符合要求的点列表

getVertexList

public static java.util.List<java.lang.Long> getVertexList(Graph graph,
                                                           java.util.List<java.lang.Long> ids,
                                                           java.util.Set<java.lang.Integer> vertexTypes)

获取点类型过滤后的点列表

Parameters:

graph - 图对象

ids - 点集合

vertexTypes - 点类型列表

Returns:

符合要求的点列表

getVertexList

public static java.util.List<java.lang.Long> getVertexList(Graph graph,
                                                           java.util.List<java.lang.Long> ids,
                                                           java.util.function.Predicate<Element> vertexCondition)

获取点属性过滤后的点列表

Parameters:

graph - 图对象

ids - 点集合

vertexCondition - 点属性过滤

Returns:

符合要求的点列表

getProperty

public static java.util.Map<java.lang.Long,java.lang.Object> getProperty(Graph graph,
                                                                         java.util.List<java.lang.Long> ids,
                                                                         java.lang.String propertyName)

批量获取点属性

Parameters:

graph - 图对象

ids - 起始点集合

propertyName - 属性名称

Returns:

起始点id和属性

getProperty

public static java.util.Map<java.lang.Long,java.util.List<java.lang.Object>> getProperty(Graph graph,
                                                                                         java.util.List<java.lang.Long> ids,
                                                                                         java.lang.String... propertyNames)

批量获取点属性

Parameters:

graph - 图对象

ids - 起始点集合

propertyNames - 属性名称集合

Returns:

起始点id和属性集合

getVertexIds

public static java.util.Set<java.lang.Long> getVertexIds(Graph graph,
                                                         java.util.Set<java.lang.Integer> vertexTypes,
                                                         java.util.function.Predicate<Element> vertexCondition)

通过类型属性过滤获取一批点id

Parameters:

graph - 图对象

vertexTypes - 点类型列表

vertexCondition - 点属性过滤

Returns:

符合条件的点集合

getVertexIds

public static java.util.Set<java.lang.Long> getVertexIds(Graph graph,
                                                         java.util.Set<java.lang.Integer> vertexTypes)

通过类型过滤获取一批点id

Parameters:

graph - 图对象

vertexTypes - 点类型列表

Returns:

符合条件的点集合

getVertexIds

public static java.util.Set<java.lang.Long> getVertexIds(Graph graph,
                                                         java.util.function.Predicate<Element> vertexCondition)

通过属性过滤获取一批点id

Parameters:

graph - 图对象

vertexCondition - 点属性过滤

Returns:

符合条件的点集合

getVertexIdsFast

public static java.util.Set<java.lang.Long> getVertexIdsFast(Graph graph,
                                                             java.util.Set<java.lang.Integer> vertexTypes,
                                                             java.util.function.Predicate<Element> vertexCondition)

通过类型属性过滤获取一批点id，多线程加速

Parameters:

graph - 图对象

vertexTypes - 点类型列表

vertexCondition - 点属性过滤

Returns:

符合条件的点集合

getVertexIdsFast

public static java.util.Set<java.lang.Long> getVertexIdsFast(Graph graph,
                                                             java.util.Set<java.lang.Integer> vertexTypes)

通过类型过滤获取一批点id，多线程加速

Parameters:

graph - 图对象

vertexTypes - 点类型列表

Returns:

符合条件的点集合

getVertexIdsFast

public static java.util.Set<java.lang.Long> getVertexIdsFast(Graph graph,
                                                             java.util.function.Predicate<Element> vertexCondition)

通过属性过滤获取一批点id，多线程加速

Parameters:

graph - 图对象

vertexCondition - 点属性过滤

Returns:

符合条件的点集合

convertDirection

public static Direction convertDirection(java.lang.String direction)

方向转换

Parameters:

direction - 方向名称 ["OUT", "IN", "BOTH"]

Returns:

方向

reverseDirection

public static Direction reverseDirection(Direction direction)

反转方向

Parameters:

direction - 初始方向

Returns:

反转后的方向

convertVertexTypeName

public static java.util.Set<java.lang.Integer> convertVertexTypeName(Graph graph,
                                                                     java.util.Set<java.lang.String> vertexTypeNames)

转换点类型名到点类型index

Parameters:

graph - 图对象

vertexTypeNames - 点类型名集合

Returns:

点类型index集合

convertVertexTypeName

public static java.util.Set<java.lang.Integer> convertVertexTypeName(Graph graph,
                                                                     java.lang.String... vertexTypeNames)

转换点类型名到点类型index

Parameters:

graph - 图对象

vertexTypeNames - 点类型名集合

Returns:

点类型index集合

convertEdgeTypeName

public static java.util.Set<java.lang.Integer> convertEdgeTypeName(Graph graph,
                                                                   java.util.Set<java.lang.String> edgeTypeNames)

转换边类型名到边类型index

Parameters:

graph - 图对象

edgeTypeNames - 点类型名集合

Returns:

边类型index集合

convertEdgeTypeName

public static java.util.Set<java.lang.Integer> convertEdgeTypeName(Graph graph,
                                                                   java.lang.String... edgeTypeNames)

转换边类型名到边类型index

Parameters:

graph - 图对象

edgeTypeNames - 点类型名集合

Returns:

边类型index集合