public interface EngineGraph
Modifier and Type | Method and Description |
---|---|
boolean |
containAllSeqId(int seqId)
判断集群点是否存在。
|
boolean |
containLocalSeqId(int seqId)
判断本机点是否存在。
|
default boolean |
containSeqId(int seqId,
boolean isLocal)
判断点是否存在。
|
default long |
getAllEdgeCount()
获取集群合法边总数。
|
default int |
getAllVertexCount()
获取集群点总数。
|
int |
getClusterNodeId(int seqId)
获取点的机器号。
当点不存在时会抛出点不存在异常。
|
long |
getEdgeCount(boolean isLocal)
获取合法边总数。
|
default long |
getEdgeCount(int typeIndex)
获取集群给定边类型编号合法边总数。
|
long |
getEdgeCount(int typeIndex,
int clusterNodeId)
获取机器号和边类型编号对应的合法边总数。
|
EngineMetrics |
getEngineMetrics()
获取图引擎指标。
|
java.lang.String |
getEngineName()
获取图引擎名。
|
Graph |
getGraph()
获取图操作对象。
|
IdsMap |
getIdsMap()
获取图引擎ID映射器。
|
long |
getLongPrimaryKey(int seqId)
通过点ID获取点主键,配合STRING_TO_LONG使用。
|
int |
getMaxSeqId()
获取最大的点(不包含本身),其中
0 <= seq id < max seq id 。 |
java.lang.String |
getPrimaryKey(int seqId)
通过点ID获取点主键。
|
int |
getSeqId(long vertexId)
通过内部ID获取点ID。
|
int |
getVertexCount(boolean isLocal)
获取点总数。
|
default int |
getVertexCount(int typeIndex)
获取点类型对应的点总数。
|
int |
getVertexCount(int typeIndex,
int clusterNodeId)
获取特定机器点类型对应的点总数。
|
long |
getVertexId(int seqId)
通过点ID获取内部ID。
|
int |
getVertexTypeIndex(int seqId)
获取点的类型编号。
|
default EngineVertexIterator |
retrieveAllVertexes()
同retrieveAllVertexes(null)。
|
EngineVertexIterator |
retrieveAllVertexes(EngineVertexParam param)
获取集群点迭代器,填null表示过滤不生效。
|
default void |
retrieveAllVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer)
同retrieveAllVertexesParallel(consumer, null)。
|
void |
retrieveAllVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer,
EngineVertexParam param)
并行集群点迭代,填null表示过滤不生效。
|
default int |
retrieveDegree(int seqId,
Direction direction)
同retrieveDegreeBySeqId(seqId, direction, null)。
|
int |
retrieveDegree(int seqId,
Direction direction,
EngineEdgeParam param)
检索度数,填null表示过滤不生效。
|
default EngineEdgeIterator |
retrieveEdge(int seqId,
Direction direction)
同retrieveEdge(seqId, null)。
|
EngineEdgeIterator |
retrieveEdge(int seqId,
Direction direction,
EngineEdgeParam param)
检索边,填null表示过滤不生效。
|
default EngineIdIterator |
retrieveEdgeId(int seqId,
Direction direction)
同retrieveEdgeId(seqId, direction, null)。
|
EngineIdIterator |
retrieveEdgeId(int seqId,
Direction direction,
EngineEdgeParam param)
检索边ID,填null表示过滤不生效。
|
default EngineVertexIterator |
retrieveLocalVertexes()
同retrieveLocalVertexes(null)。
|
EngineVertexIterator |
retrieveLocalVertexes(EngineVertexParam param)
检索本机所有点,填null表示过滤不生效。
|
default void |
retrieveLocalVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer)
同retrieveLocalVertexesParallel(consumer, null)。
|
void |
retrieveLocalVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer,
EngineVertexParam param)
并行检索本机所有点,填null表示过滤不生效。
|
boolean |
retrieveVertexBooleanProperty(int seqId,
java.lang.String propertyName)
通过点ID及点属性名获取点布尔属性,属性不存在或属性值为空返回
EngineDataType.BOOLEAN_NULL_VALUE 。 |
byte |
retrieveVertexByteProperty(int seqId,
java.lang.String propertyName)
通过点ID及点属性名获取点字节属性,属性不存在或属性值为空返回
EngineDataType.BYTE_NULL_VALUE 。 |
double |
retrieveVertexDecimalProperty(int seqId,
java.lang.String propertyName)
通过点ID及点属性名获取点浮点属性,属性不存在或属性值为空返回
EngineDataType.DOUBLE_NULL_VALUE 。 |
double |
retrieveVertexDoubleProperty(int seqId,
java.lang.String propertyName)
通过点ID及点属性名获取点双精度属性,属性不存在或属性值为空返回
EngineDataType.DOUBLE_NULL_VALUE 。 |
default EngineVertexIterator |
retrieveVertexes(boolean isLocal)
同retrieveVertexes(null, isLocal)。
|
default EngineVertexIterator |
retrieveVertexes(EngineVertexParam param,
boolean isLocal)
获取点迭代器,填null表示过滤不生效。
|
default void |
retrieveVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer,
boolean isLocal)
同retrieveVertexesParallel(consumer, null, isLocal)。
|
default void |
retrieveVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer,
EngineVertexParam param,
boolean isLocal)
并行点迭代,填null表示过滤不生效。
|
long |
retrieveVertexIntegerProperty(int seqId,
java.lang.String propertyName)
通过点ID及点属性名获取点整数属性,属性不存在或属性值为空返回
EngineDataType.LONG_NULL_VALUE 。 |
int |
retrieveVertexIntProperty(int seqId,
java.lang.String propertyName)
通过点ID及点属性名获取点短整型属性,属性不存在或属性值为空返回
EngineDataType.INT_NULL_VALUE 。 |
long |
retrieveVertexLongProperty(int seqId,
java.lang.String propertyName)
通过点ID及点属性名获取点长整型属性,属性不存在或属性值为空返回
EngineDataType.LONG_NULL_VALUE 。 |
double |
retrieveVertexNumberProperty(int seqId,
java.lang.String propertyName)
通过点ID及点属性名获取点数值属性,属性不存在或属性值为空返回
EngineDataType.DOUBLE_NULL_VALUE 。 |
java.util.Map<java.lang.String,java.lang.Object> |
retrieveVertexProperties(int seqId)
获取点的全部属性。
|
java.lang.String |
retrieveVertexStringProperty(int seqId,
java.lang.String propertyName)
通过点ID及点属性名获取点字符串属性,属性不存在或属性值为空返回
EngineDataType.REF_NULL_VALUE 。 |
EngineSchema |
schema()
获取图模型。
|
EngineStartupMeta |
startupMeta()
获取启动元信息。
|
java.lang.String getEngineName()
Graph getGraph()
EngineSchema schema()
EngineStartupMeta startupMeta()
IdsMap getIdsMap()
EngineMetrics getEngineMetrics()
boolean containLocalSeqId(int seqId)
seqId
- 点ID。boolean containAllSeqId(int seqId)
seqId
- 点ID。default boolean containSeqId(int seqId, boolean isLocal)
seqId
- 点ID。isLocal
- 判断本机点是否存在。int getVertexTypeIndex(int seqId)
当点不存在时会抛出点不存在异常。
seqId
- 点ID。int getClusterNodeId(int seqId)
seqId
- 点ID。java.util.Map<java.lang.String,java.lang.Object> retrieveVertexProperties(int seqId)
当点不存在时会抛出点不存在异常。
seqId
- 点ID。default EngineVertexIterator retrieveLocalVertexes()
EngineVertexIterator retrieveLocalVertexes(EngineVertexParam param)
param
- 可选参数。default void retrieveLocalVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
consumer
- 针对每个点进行操作。java.util.concurrent.ExecutionException
java.lang.InterruptedException
void retrieveLocalVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer, EngineVertexParam param) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
consumer
- 针对每个点进行操作。param
- 可选参数。java.util.concurrent.ExecutionException
java.lang.InterruptedException
default EngineVertexIterator retrieveAllVertexes()
EngineVertexIterator retrieveAllVertexes(EngineVertexParam param)
param
- 可选参数。default void retrieveAllVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
consumer
- 针对每个点进行操作。java.util.concurrent.ExecutionException
java.lang.InterruptedException
void retrieveAllVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer, EngineVertexParam param) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
consumer
- 针对每个点进行操作。param
- 可选参数。java.util.concurrent.ExecutionException
java.lang.InterruptedException
default EngineVertexIterator retrieveVertexes(boolean isLocal)
isLocal
- 本机点迭代。default EngineVertexIterator retrieveVertexes(EngineVertexParam param, boolean isLocal)
param
- 可选参数。isLocal
- 本机点迭代。default void retrieveVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer, boolean isLocal) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
consumer
- 针对每个点进行操作。isLocal
- 本机点迭代。java.util.concurrent.ExecutionException
java.lang.InterruptedException
default void retrieveVertexesParallel(java.util.function.Consumer<EngineVertexIterator> consumer, EngineVertexParam param, boolean isLocal) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
consumer
- 针对每个点进行操作。param
- 可选参数。isLocal
- 本机点迭代。java.util.concurrent.ExecutionException
java.lang.InterruptedException
int getMaxSeqId()
0 <= seq id < max seq id
。int getSeqId(long vertexId)
当点不存在时会抛出点不存在异常。
vertexId
- 内部ID。long getVertexId(int seqId)
当点不存在时会抛出点不存在异常。
seqId
- 点ID。java.lang.String getPrimaryKey(int seqId)
当点不存在时会抛出点不存在异常。 当点主键未被存储时会抛出点主键属性不存在异常。
seqId
- 点ID。long getLongPrimaryKey(int seqId)
当点不存在时会抛出点不存在异常。 当点主键未被存储时会抛出点主键属性不存在异常。
seqId
- 点ID。boolean retrieveVertexBooleanProperty(int seqId, java.lang.String propertyName)
EngineDataType.BOOLEAN_NULL_VALUE
。
当点不存在时会抛出点不存在异常。 当点属性不存在时会抛出点属性不存在异常。 当点属性非布尔类型时会抛出类型不匹配异常。
seqId
- 点ID。propertyName
- 点属性名。int retrieveVertexIntProperty(int seqId, java.lang.String propertyName)
EngineDataType.INT_NULL_VALUE
。
当点不存在时会抛出点不存在异常。 当点属性不存在时会抛出点属性不存在异常。 当点属性非短整型类型时会抛出类型不匹配异常。
seqId
- 点ID。propertyName
- 点属性名。long retrieveVertexLongProperty(int seqId, java.lang.String propertyName)
EngineDataType.LONG_NULL_VALUE
。
当点不存在时会抛出点不存在异常。 当点属性不存在时会抛出点属性不存在异常。 当点属性非长整型类型时会抛出类型不匹配异常。
seqId
- 点ID。propertyName
- 点属性名。double retrieveVertexDoubleProperty(int seqId, java.lang.String propertyName)
EngineDataType.DOUBLE_NULL_VALUE
。
当点不存在时会抛出点不存在异常。 当点属性不存在时会抛出点属性不存在异常。 当点属性非双精度类型时会抛出类型不匹配异常。
seqId
- 点ID。propertyName
- 点属性名。java.lang.String retrieveVertexStringProperty(int seqId, java.lang.String propertyName)
EngineDataType.REF_NULL_VALUE
。
当点不存在时会抛出点不存在异常。 当点属性不存在时会抛出点属性不存在异常。 当点属性非字符串类型时会抛出类型不匹配异常。
seqId
- 点ID。propertyName
- 点属性名。long retrieveVertexIntegerProperty(int seqId, java.lang.String propertyName)
EngineDataType.LONG_NULL_VALUE
。
当点不存在时会抛出点不存在异常。 当点属性不存在时会抛出点属性不存在异常。 当点属性非整数类型时会抛出类型不匹配异常。
seqId
- 点ID。propertyName
- 点属性名。double retrieveVertexDecimalProperty(int seqId, java.lang.String propertyName)
EngineDataType.DOUBLE_NULL_VALUE
。
当点不存在时会抛出点不存在异常。 当点属性不存在时会抛出点属性不存在异常。 当点属性非浮点类型时会抛出类型不匹配异常。
seqId
- 点ID。propertyName
- 点属性名。double retrieveVertexNumberProperty(int seqId, java.lang.String propertyName)
EngineDataType.DOUBLE_NULL_VALUE
。
当点不存在时会抛出点不存在异常。 当点属性不存在时会抛出点属性不存在异常。 当点属性非数值类型时会抛出类型不匹配异常。
seqId
- 点ID。propertyName
- 点属性名。byte retrieveVertexByteProperty(int seqId, java.lang.String propertyName)
EngineDataType.BYTE_NULL_VALUE
。
当点不存在时会抛出点不存在异常。 当点属性不存在时会抛出点属性不存在异常。 当点属性非字节类型时会抛出类型不匹配异常。
seqId
- 点ID。propertyName
- 点属性名。default int getAllVertexCount()
int getVertexCount(boolean isLocal)
isLocal
- true表示本机,false表示集群。default int getVertexCount(int typeIndex)
typeIndex
- 点类型编号。int getVertexCount(int typeIndex, int clusterNodeId)
typeIndex
- 点类型编号。clusterNodeId
- 机器号。default EngineEdgeIterator retrieveEdge(int seqId, Direction direction)
seqId
- 点ID。direction
- 检索方向。EngineEdgeIterator retrieveEdge(int seqId, Direction direction, EngineEdgeParam param)
seqId
- 点ID。direction
- 检索方向。param
- 可选参数。default int retrieveDegree(int seqId, Direction direction)
seqId
- 点ID。direction
- 检索方向。int retrieveDegree(int seqId, Direction direction, EngineEdgeParam param)
seqId
- 点ID。direction
- 检索方向。param
- 可选参数。default long getAllEdgeCount()
long getEdgeCount(boolean isLocal)
isLocal
- 本机。default long getEdgeCount(int typeIndex)
typeIndex
- 边类型编号。long getEdgeCount(int typeIndex, int clusterNodeId)
typeIndex
- 边类型编号。clusterNodeId
- 机器号。default EngineIdIterator retrieveEdgeId(int seqId, Direction direction)
seqId
- 点ID。direction
- 检索方向。EngineIdIterator retrieveEdgeId(int seqId, Direction direction, EngineEdgeParam param)
seqId
- 点ID。direction
- 检索方向。param
- 可选参数。