public class PgxGraph extends PgxManagedObject implements java.lang.Cloneable
Modifier and Type | Class and Description |
---|---|
static class |
PgxGraph.Degree
The degree.
|
static class |
PgxGraph.Mode
The mutation mode.
|
static class |
PgxGraph.MultiEdges
The multi-edges behavior.
|
static class |
PgxGraph.SelfEdges
The self-edges behavior.
|
static class |
PgxGraph.SortOrder
The direction.
|
static class |
PgxGraph.TrivialVertices
The trivial vertices behavior.
|
Modifier and Type | Method and Description |
---|---|
BipartiteGraph |
bipartiteSubGraphFromInDegree()
Blocking version of
bipartiteSubGraphFromInDegreeAsync() . |
BipartiteGraph |
bipartiteSubGraphFromInDegree(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName)
Blocking version of
bipartiteSubGraphFromInDegreeAsync(Collection, Collection, String) . |
BipartiteGraph |
bipartiteSubGraphFromInDegree(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName, java.lang.String isLeftPropName, boolean inPlace)
Blocking version of
bipartiteSubGraphFromInDegreeAsync(Collection, Collection, String, String, boolean) . |
BipartiteGraph |
bipartiteSubGraphFromInDegree(java.lang.String newGraphName)
Blocking version of
bipartiteSubGraphFromInDegreeAsync(String) . |
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromInDegreeAsync()
Create a bipartite version of this graph with all vertices of in-degree = 0 being the left set.
|
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromInDegreeAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName)
Create a bipartite version of this graph with all vertices of in-degree = 0 being the left set.
|
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromInDegreeAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName, java.lang.String isLeftPropName, boolean inPlace)
Create a bipartite version of this graph with all vertices of in-degree = 0 being the left set.
|
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromInDegreeAsync(java.lang.String newGraphName)
Create a bipartite version of this graph with all vertices of in-degree = 0 being the left set.
|
BipartiteGraph |
bipartiteSubGraphFromLeftSet(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, java.lang.String newGraphName)
Blocking version of
bipartiteSubGraphFromLeftSetAsync(Collection, Collection, VertexSet, String) . |
BipartiteGraph |
bipartiteSubGraphFromLeftSet(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, java.lang.String newGraphName, java.lang.String isLeftPropName)
Blocking version of
bipartiteSubGraphFromLeftSetAsync(Collection, Collection, VertexSet, String, String) . |
BipartiteGraph |
bipartiteSubGraphFromLeftSet(VertexSet<?> vertexSet)
Blocking version of
bipartiteSubGraphFromLeftSetAsync(VertexSet) . |
BipartiteGraph |
bipartiteSubGraphFromLeftSet(VertexSet<?> vertexSet, java.lang.String newGraphName)
Blocking version of
bipartiteSubGraphFromLeftSetAsync(VertexSet, String) . |
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromLeftSetAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, java.lang.String newGraphName)
Create a bipartite version of this graph with the given vertex set being the left set.
|
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromLeftSetAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, java.lang.String newGraphName, java.lang.String isLeftPropName)
Create a bipartite version of this graph with the given vertex set being the left set.
|
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromLeftSetAsync(VertexSet<?> vertexSet)
Create a bipartite version of this graph with the given vertex set being the left set.
|
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromLeftSetAsync(VertexSet<?> vertexSet, java.lang.String newGraphName)
Create a bipartite version of this graph with the given vertex set being the left set.
|
PgxGraph |
clone()
Blocking version of
cloneAsync() . |
PgxGraph |
clone(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName)
Blocking version of
cloneAsync() . |
PgxGraph |
clone(java.lang.String newGraphName)
Blocking version of
cloneAsync(String) . |
PgxFuture<PgxGraph> |
cloneAsync()
|
PgxFuture<PgxGraph> |
cloneAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName)
Creates a copy of this graph.
|
PgxFuture<PgxGraph> |
cloneAsync(java.lang.String newGraphName)
Convenience method of
cloneAsync(Collection, Collection, String) Passing Collection(vertexProperties) as VertexProperty.ALL Collection(edgeProperties) as EdgeProperty.ALL |
<E> EdgeProperty<PgxVect<E>> |
combineEdgePropertiesIntoVectorProperty(java.util.List<EdgeProperty<E>> edgePropertyList)
Blocking version of
combineEdgePropertiesIntoVectorPropertyAsync(List) Calls combineEdgePropertiesIntoVectorPropertyAsync(List) and waits for the returned PgxFuture to complete. |
<E> EdgeProperty<PgxVect<E>> |
combineEdgePropertiesIntoVectorProperty(java.util.List<EdgeProperty<E>> edgePropertyList, java.lang.String name)
Blocking version of
combineEdgePropertiesIntoVectorPropertyAsync(List, String) Calls combineEdgePropertiesIntoVectorPropertyAsync(List, String) and waits for the returned PgxFuture to complete. |
<E> PgxFuture<EdgeProperty<PgxVect<E>>> |
combineEdgePropertiesIntoVectorPropertyAsync(java.util.List<EdgeProperty<E>> edgePropertyList)
Takes a list of scalar edge properties of same type and creates a new edge vector property by combining them.
|
<E> PgxFuture<EdgeProperty<PgxVect<E>>> |
combineEdgePropertiesIntoVectorPropertyAsync(java.util.List<EdgeProperty<E>> edgePropertyList, java.lang.String name)
Takes a list of scalar edge properties of same type and creates a new edge vector property by combining them.
|
<ID,V> VertexProperty<ID,PgxVect<V>> |
combineVertexPropertiesIntoVectorProperty(java.util.List<VertexProperty<ID,V>> vertexPropertyList)
Blocking version of
combineVertexPropertiesIntoVectorPropertyAsync(List) Calls combineVertexPropertiesIntoVectorPropertyAsync(List) and waits for the returned PgxFuture to complete. |
<ID,V> VertexProperty<ID,PgxVect<V>> |
combineVertexPropertiesIntoVectorProperty(java.util.List<VertexProperty<ID,V>> vertexPropertyList, java.lang.String name)
Blocking version of
combineVertexPropertiesIntoVectorPropertyAsync(List, String) Calls combineVertexPropertiesIntoVectorPropertyAsync(List, String) and waits for the returned PgxFuture to complete. |
<ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> |
combineVertexPropertiesIntoVectorPropertyAsync(java.util.List<VertexProperty<ID,V>> vertexPropertyList)
Takes a list of scalar vertex properties of same type and creates a new vertex vector property by combining them.
|
<ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> |
combineVertexPropertiesIntoVectorPropertyAsync(java.util.List<VertexProperty<ID,V>> vertexPropertyList, java.lang.String name)
Takes a list of scalar vertex properties of same type and creates a new vertex vector property by combining them.
|
<ID extends java.lang.Comparable<ID>> |
createAllPaths(PgxVertex<ID> src, EdgeProperty<java.lang.Double> cost, VertexProperty<ID,java.lang.Double> dist, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge)
|
<ID> PgxFuture<AllPaths<ID>> |
createAllPathsAsync(PgxVertex<ID> src, EdgeProperty<java.lang.Double> cost, VertexProperty<ID,java.lang.Double> dist, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge)
Creates a
AllPaths object representing all the shortest paths from a single source to all the possible destinations (shortest regarding the given edge costs). |
<ID extends java.lang.Comparable<ID>> |
createChangeSet()
Creates a change set for updating the graph.
|
<ID> Partition<ID> |
createComponents(VertexProperty<ID,java.lang.Long> components, long numComponents)
Blocking version of
createComponentsAsync(VertexProperty, long) . |
<ID> PgxFuture<Partition<ID>> |
createComponentsAsync(VertexProperty<ID,java.lang.Long> components, long numComponents)
Creates a
Partition object holding a collection of vertex sets, each representing a component. |
<V> EdgeProperty<V> |
createEdgeProperty(PropertyType type)
Blocking version of
createEdgePropertyAsync(PropertyType) . |
<V> EdgeProperty<V> |
createEdgeProperty(PropertyType type, int dimension, java.lang.String name, boolean hardName)
Blocking version of
createEdgePropertyAsync(PropertyType, int, String, boolean) . |
<V> EdgeProperty<V> |
createEdgeProperty(PropertyType type, java.lang.String name)
Blocking version of
createEdgePropertyAsync(PropertyType, String) . |
<V> PgxFuture<EdgeProperty<V>> |
createEdgePropertyAsync(PropertyType type)
Creates a session-bound edge property
|
<V> PgxFuture<EdgeProperty<V>> |
createEdgePropertyAsync(PropertyType type, java.lang.String name)
Creates a session-bound edge property
|
EdgeSequence |
createEdgeSequence()
Blocking version of
createEdgeSequenceAsync() . |
EdgeSequence |
createEdgeSequence(java.lang.String name)
Blocking version of
createEdgeSequenceAsync(String) . |
PgxFuture<EdgeSequence> |
createEdgeSequenceAsync()
Creates a new edge sequence.
|
PgxFuture<EdgeSequence> |
createEdgeSequenceAsync(java.lang.String name)
Creates a new edge sequence.
|
EdgeSet |
createEdgeSet()
Blocking version of
createEdgeSetAsync() . |
EdgeSet |
createEdgeSet(java.lang.String name)
Blocking version of
createEdgeSetAsync(String) . |
PgxFuture<EdgeSet> |
createEdgeSetAsync()
Creates a new edge set.
|
PgxFuture<EdgeSet> |
createEdgeSetAsync(java.lang.String name)
Creates a new edge set.
|
<V> EdgeProperty<PgxVect<V>> |
createEdgeVectorProperty(PropertyType type, int dimension)
Blocking version of
createEdgeVectorPropertyAsync(PropertyType, int) . |
<V> EdgeProperty<PgxVect<V>> |
createEdgeVectorProperty(PropertyType type, int dimension, java.lang.String name)
Blocking version of
createEdgeVectorPropertyAsync(PropertyType, int, String) . |
<V> PgxFuture<EdgeProperty<PgxVect<V>>> |
createEdgeVectorPropertyAsync(PropertyType type, int dimension)
Creates a session-bound edge vector property
|
<V> PgxFuture<EdgeProperty<PgxVect<V>>> |
createEdgeVectorPropertyAsync(PropertyType type, int dimension, java.lang.String name)
Creates a session-bound edge vector property
|
<K,V> PgxMap<K,V> |
createMap(PropertyType keyType, PropertyType valType)
Blocking version of
createMapAsync(PropertyType, PropertyType) . |
<K,V> PgxMap<K,V> |
createMap(PropertyType keyType, PropertyType valType, java.lang.String mapName)
Blocking version of
createMapAsync(PropertyType, PropertyType, String) . |
<K,V> PgxFuture<PgxMap<K,V>> |
createMapAsync(PropertyType keyType, PropertyType valType)
Creates a session-bound map
|
<K,V> PgxFuture<PgxMap<K,V>> |
createMapAsync(PropertyType keyType, PropertyType valType, java.lang.String mapName)
Creates a session-bound map
|
MergingStrategyBuilder |
createMergingStrategyBuilder()
Creates a new
MergingStrategyBuilder that can be used to build a new MutationStrategy to simplify this graph. |
<ID> PgxPath<ID> |
createPath(PgxVertex<ID> src, PgxVertex<ID> dst, EdgeProperty<java.lang.Double> cost, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge)
Blocking version of
createPathAsync(PgxVertex, PgxVertex, EdgeProperty, VertexProperty, VertexProperty) . |
<ID> PgxFuture<PgxPath<ID>> |
createPathAsync(PgxVertex<ID> src, PgxVertex<ID> dst, EdgeProperty<java.lang.Double> cost, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge)
Creates a
PgxPath object representing the shortest path from one source to one destination (shortest regarding the given edge costs). |
PickingStrategyBuilder |
createPickingStrategyBuilder()
Creates a new
PickingStrategyBuilder that can be used to build a new PickingStrategy to simplify this graph. |
<T> Scalar<T> |
createScalar(PropertyType type)
Blocking version of
createScalarAsync(PropertyType) . |
<T> Scalar<T> |
createScalar(PropertyType type, java.lang.String newScalarName)
Blocking version of
createScalarAsync(PropertyType, String) . |
<T> PgxFuture<Scalar<T>> |
createScalarAsync(PropertyType type)
Creates a new Scalar.
|
<T> PgxFuture<Scalar<T>> |
createScalarAsync(PropertyType type, java.lang.String newScalarName)
Create a session-bound scalar.
|
<T> Scalar<PgxVect<T>> |
createVectorScalar(PropertyType type, int dimension)
Blocking version of
createVectorScalarAsync(PropertyType, int) . |
<T> Scalar<PgxVect<T>> |
createVectorScalar(PropertyType type, int dimension, java.lang.String newScalarName)
Blocking version of
createVectorScalarAsync(PropertyType, int, String) . |
<T> PgxFuture<Scalar<PgxVect<T>>> |
createVectorScalarAsync(PropertyType type, int dimension)
Create a session-bound vector scalar.
|
<T> PgxFuture<Scalar<PgxVect<T>>> |
createVectorScalarAsync(PropertyType type, int dimension, java.lang.String newScalarName)
Create a session-bound vector scalar.
|
<ID,V> VertexProperty<ID,V> |
createVertexProperty(PropertyType type)
Blocking version of
createVertexPropertyAsync(PropertyType) . |
<ID,V> VertexProperty<ID,V> |
createVertexProperty(PropertyType type, int dimension, java.lang.String name, boolean hardName)
Blocking version of
createVertexPropertyAsync(PropertyType, int, String, boolean) . |
<ID,V> VertexProperty<ID,V> |
createVertexProperty(PropertyType type, java.lang.String name)
Blocking version of
createVertexPropertyAsync(PropertyType, String) . |
<ID,V> PgxFuture<VertexProperty<ID,V>> |
createVertexPropertyAsync(PropertyType type)
Creates a session-bound vertex property
|
<ID,V> PgxFuture<VertexProperty<ID,V>> |
createVertexPropertyAsync(PropertyType type, java.lang.String name)
Creates a session-bound vertex property
|
<E> VertexSequence<E> |
createVertexSequence()
Blocking version of
createVertexSequenceAsync() . |
<E> VertexSequence<E> |
createVertexSequence(java.lang.String name)
Blocking version of
createVertexSequenceAsync(String) . |
<E> PgxFuture<VertexSequence<E>> |
createVertexSequenceAsync()
Creates a new vertex sequence.
|
<E> PgxFuture<VertexSequence<E>> |
createVertexSequenceAsync(java.lang.String name)
Creates a new vertex sequence.
|
<E> VertexSet<E> |
createVertexSet()
Blocking version of
createVertexSetAsync() . |
<E> VertexSet<E> |
createVertexSet(java.lang.String name)
Blocking version of
createVertexSetAsync(String) . |
<E> PgxFuture<VertexSet<E>> |
createVertexSetAsync()
Creates a new vertex set.
|
<E> PgxFuture<VertexSet<E>> |
createVertexSetAsync(java.lang.String name)
Creates a new vertex set.
|
<ID,V> VertexProperty<ID,PgxVect<V>> |
createVertexVectorProperty(PropertyType type, int dimension)
Blocking version of
createVertexVectorPropertyAsync(PropertyType, int) . |
<ID,V> VertexProperty<ID,PgxVect<V>> |
createVertexVectorProperty(PropertyType type, int dimension, java.lang.String name)
Blocking version of
createVertexVectorPropertyAsync(PropertyType, int, String) . |
<ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> |
createVertexVectorPropertyAsync(PropertyType type, int dimension)
Creates a session-bound vertex vector property
|
<ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> |
createVertexVectorPropertyAsync(PropertyType type, int dimension, java.lang.String name)
Creates a session-bound vertex vector property
|
PgxGraph |
filter(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, GraphFilter graphFilter, java.lang.String newGraphName)
Blocking version of
filterAsync(Collection, Collection, GraphFilter, String) . |
PgxGraph |
filter(GraphFilter graphFilter)
Blocking version of
filterAsync(GraphFilter) . |
PgxGraph |
filter(GraphFilter graphFilter, java.lang.String newGraphName)
Blocking version of
filterAsync(GraphFilter, String) . |
PgxFuture<PgxGraph> |
filterAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, GraphFilter graphFilter, java.lang.String newGraphName)
Create a subgraph of this graph.
|
PgxFuture<PgxGraph> |
filterAsync(GraphFilter graphFilter)
Create a subgraph of this graph.
|
PgxFuture<PgxGraph> |
filterAsync(GraphFilter graphFilter, java.lang.String newGraphName)
Create a subgraph of this graph.
|
GraphConfig |
getConfig()
Gets the graph configuration object used to specify the data source of this graph.
|
long |
getCreationRequestTimestamp()
Gets the timestamp when this graph was requested to be created.
|
long |
getCreationTimestamp()
Gets the timestamp when this graph finished creation.
|
java.lang.String |
getDataSourceVersion()
Gets the format-specific version identifier provided by data-source (timestamp for files, snapshot ID for databases).
|
PgxEdge |
getEdge(long id)
Blocking version of
getEdgeAsync(long) Calls getEdgeAsync(long) and waits for the returned PgxFuture to complete. |
PgxFuture<PgxEdge> |
getEdgeAsync(long id)
Looks up a
PgxEdge of this graph by ID. |
EdgeLabel |
getEdgeLabel()
Blocking version of
getEdgeLabelAsync() . |
PgxFuture<EdgeLabel> |
getEdgeLabelAsync()
Get the edge labels belonging to this graph.
|
java.util.Set<EdgeProperty<?>> |
getEdgeProperties()
Blocking version of
getEdgePropertiesAsync() . |
PgxFuture<java.util.Set<EdgeProperty<?>>> |
getEdgePropertiesAsync()
Get the set of edge properties belonging to this graph.
|
<V> EdgeProperty<V> |
getEdgeProperty(java.lang.String name)
Blocking version of
getEdgePropertyAsync(String) . |
<V> PgxFuture<EdgeProperty<V>> |
getEdgePropertyAsync(java.lang.String name)
Gets an edge property of this graph
|
EdgeSet |
getEdges()
Blocking version of
getEdges() . |
EdgeSet |
getEdges(EdgeFilter filter)
Blocking version of
getEdges(EdgeFilter) . |
PgxFuture<EdgeSet> |
getEdgesAsync()
Creates a new edge set containing all edges.
|
<E> PgxFuture<EdgeSet> |
getEdgesAsync(EdgeFilter filter)
Creates a new edge set containing edges according to the given filter expression.
|
long |
getMemoryMb()
Gets the estimated number of memory this graph (including its properties) consumes in memory (in megabytes).
|
java.lang.String |
getName()
Gets the name.
|
long |
getNumEdges()
Gets the number of edges
|
long |
getNumVertices()
Gets the number of vertices
|
ServerInstance |
getPgxInstance()
Gets the server instance.
|
PgxSession |
getSession()
Gets the session.
|
<ID> PgxVertex<ID> |
getVertex(ID id)
Blocking version of
getVertexAsync(Object) . |
<ID> PgxFuture<PgxVertex<ID>> |
getVertexAsync(ID id)
Looks up a
PgxVertex of this graph by ID. |
IdType |
getVertexIdType()
Gets the vertex ID type of this graph.
|
<ID> VertexLabels<ID> |
getVertexLabels()
Blocking version of
getVertexLabelsAsync() . |
<ID> PgxFuture<VertexLabels<ID>> |
getVertexLabelsAsync()
Get the vertex labels belonging to this graph.
|
java.util.Set<VertexProperty<?,?>> |
getVertexProperties()
Blocking version of
getVertexPropertiesAsync() . |
PgxFuture<java.util.Set<VertexProperty<?,?>>> |
getVertexPropertiesAsync()
Get the set of vertex properties belonging to this graph.
|
<ID,V> VertexProperty<ID,V> |
getVertexProperty(java.lang.String name)
Blocking version of
getVertexPropertyAsync(String) . |
<ID,V> PgxFuture<VertexProperty<ID,V>> |
getVertexPropertyAsync(java.lang.String name)
Gets a vertex property of this graph
|
<E> VertexSet<E> |
getVertices()
Blocking version of
getVerticesAsync() . |
<E> VertexSet<E> |
getVertices(VertexFilter filter)
Blocking version of
getVerticesAsync(VertexFilter) . |
<E> VertexSet<E> |
getVertices(VertexFilter filter, java.lang.String name)
Blocking version of
getVerticesAsync(VertexFilter,String) . |
<E> PgxFuture<VertexSet<E>> |
getVerticesAsync()
Creates a new vertex set containing all vertices.
|
<E> PgxFuture<VertexSet<E>> |
getVerticesAsync(VertexFilter filter)
Creates a new vertex set containing vertices according to the given filter expression.
|
<E> PgxFuture<VertexSet<E>> |
getVerticesAsync(VertexFilter filter, java.lang.String name)
Creates a new vertex set containing vertices according to the given filter expression.
|
boolean |
hasEdge(long id)
Blocking version of
hasEdgeAsync(long) Calls hasEdgeAsync(long) and waits for the returned PgxFuture to complete. |
PgxFuture<java.lang.Boolean> |
hasEdgeAsync(long id)
Looks up whether the graph has an Edge with the given ID
|
<ID> boolean |
hasVertex(ID id)
Blocking version of
hasVertexAsync(Object) . |
<ID> PgxFuture<java.lang.Boolean> |
hasVertexAsync(ID id)
Looks up whether the graph has a Vertex with the given ID
|
java.lang.Boolean |
isBipartiteGraph(VertexProperty<?,java.lang.Boolean> isLeft)
Blocking version of
isBipartiteGraphAsync(VertexProperty) . |
<ID> PgxFuture<java.lang.Boolean> |
isBipartiteGraphAsync(VertexProperty<ID,java.lang.Boolean> isLeft)
Checks whether a given graph is a bipartite graph.
|
boolean |
isDirected() |
boolean |
isFresh()
Blocking version of
isFreshAsync() . |
PgxFuture<java.lang.Boolean> |
isFreshAsync()
Check whether an in-memory representation of a graph is fresh.
|
boolean |
isTransient()
Gets the transient flag of this graph.
|
<ID> PgxVertex<ID> |
pickRandomVertex()
Blocking version of
pickRandomVertexAsync() . |
<ID> PgxFuture<PgxVertex<ID>> |
pickRandomVertexAsync()
Picks a random vertex in the graph.
|
PgqlResultSet |
queryPgql(java.lang.String pgqlString)
Blocking version of
queryPgql(String) . |
PgqlResultSet |
queryPgql(java.lang.String pgqlString, PatternMatchingSemantic patternMatchingSemantic)
Blocking version of
queryPgql(String, PatternMatchingSemantic) . |
PgxFuture<PgqlResultSet> |
queryPgqlAsync(java.lang.String pgqlString)
Submits a pattern matching query.
|
PgxFuture<PgqlResultSet> |
queryPgqlAsync(java.lang.String pgqlString, PatternMatchingSemantic patternMatchingSemantic)
Submits a pattern matching query.
|
PgxGraph |
simplify()
Blocking version of
simplifyAsync() . |
PgxGraph |
simplify(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName)
|
PgxGraph |
simplify(oracle.pgx.common.mutations.MutationStrategy mutationStrategy) |
PgxGraph |
simplify(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName)
Blocking version of
simplifyAsync(MultiEdges, SelfEdges, TrivialVertices, Mode, String) . |
PgxGraph |
simplify(java.lang.String newGraphName)
Blocking version of
simplifyAsync(String) . |
PgxFuture<PgxGraph> |
simplifyAsync()
Convenience method around
simplifyAsync(String) passing null as graphName |
PgxFuture<PgxGraph> |
simplifyAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName)
Create a simplified version of a graph.
|
PgxFuture<PgxGraph> |
simplifyAsync(oracle.pgx.common.mutations.MutationStrategy mutationStrategy) |
PgxFuture<PgxGraph> |
simplifyAsync(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName)
Convenience method for
simplifyAsync(Collection, Collection, MultiEdges, SelfEdges, TrivialVertices, Mode, String) Passing Collection(vertexProperties) as VertexProperty.ALL Collection(edgeProperties) as EdgeProperty.ALL Create a simplified version of a graph. |
PgxFuture<PgxGraph> |
simplifyAsync(java.lang.String newGraphName)
Convenience method for
simplifyAsync(MultiEdges, SelfEdges, TrivialVertices, Mode, String) Passing StrategyType as StrategyType.REMOVE_MULTI_EDGES SelfEdges as SelfEdges.REMOVE_SELF_EDGES Trivial Vertices as TrivialVertices.REMOVE_TRIVIAL_VERTICES Mode as Mode.CREATE_COPY Create a simplified version of a graph. |
PgxGraph |
sortByDegree()
Blocking version of
sortByDegreeAsync() . |
PgxGraph |
sortByDegree(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.SortOrder sortOrder, PgxGraph.Degree degree, PgxGraph.Mode mode, java.lang.String newGraphName)
Blocking version of
sortByDegreeAsync(Collection, Collection, SortOrder, Degree, Mode, String) . |
PgxGraph |
sortByDegree(PgxGraph.SortOrder sortOrder, PgxGraph.Degree degree, PgxGraph.Mode mode, java.lang.String newGraphName)
Blocking version of
sortByDegreeAsync(SortOrder, Degree, Mode, String) . |
PgxGraph |
sortByDegree(java.lang.String newGraphName)
Blocking version of
sortByDegreeAsync(String) . |
PgxFuture<PgxGraph> |
sortByDegreeAsync()
Create a sorted version of a graph and all its properties.
|
PgxFuture<PgxGraph> |
sortByDegreeAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.SortOrder sortOrder, PgxGraph.Degree degree, PgxGraph.Mode mode, java.lang.String newGraphName)
Create a sorted version of a graph and all its properties.
|
PgxFuture<PgxGraph> |
sortByDegreeAsync(PgxGraph.SortOrder sortOrder, PgxGraph.Degree degree, PgxGraph.Mode mode, java.lang.String newGraphName)
Create a sorted version of a graph and all its properties.
|
PgxFuture<PgxGraph> |
sortByDegreeAsync(java.lang.String newGraphName)
Create a sorted version of a graph and all its properties.
|
PgxGraph |
sparsify(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, double e, java.lang.String newGraphName)
Blocking version of
sparsifyAsync(Collection, Collection, double, String) . |
PgxGraph |
sparsify(double e)
Blocking version of
sparsifyAsync(double) . |
PgxGraph |
sparsify(double e, java.lang.String newGraphName)
Blocking version of
sparsifyAsync(double, String) . |
PgxFuture<PgxGraph> |
sparsifyAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, double e, java.lang.String newGraphName)
Sparsifies the given graph and returns a new graph with less edges.
|
PgxFuture<PgxGraph> |
sparsifyAsync(double e)
Sparsifies the given graph and returns a new graph with less edges.
Convenience method around |
PgxFuture<PgxGraph> |
sparsifyAsync(double e, java.lang.String newGraphName)
Sparsifies the given graph and returns a new graph with less edges.
Convenience method around |
FileGraphConfig |
store(Format targetFormat, java.lang.String targetPath)
Blocking version of
storeAsync(Format, String) . |
FileGraphConfig |
store(Format targetFormat, java.lang.String targetPath, boolean overwrite)
Blocking version of
storeAsync(Format, String, boolean) . |
FileGraphConfig |
store(Format targetFormat, java.lang.String targetPath, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(Format, String, Collection, Collection, boolean) . |
GraphConfig |
store(GraphConfig targetConfig, boolean overwrite)
Blocking version of
storeAsync(GraphConfig, boolean) . |
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, java.lang.String targetPath)
Stores this graph in a given file format on a file system.
|
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, java.lang.String targetPath, boolean overwrite)
Stores this graph in a given file format on a file system.
|
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, java.lang.String targetPath, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Stores this graph in a given file format on a file system.
|
PgxFuture<GraphConfig> |
storeAsync(GraphConfig targetConfig, boolean overwrite)
Stores this graph in a file or database.
|
java.lang.String |
toString() |
PgxGraph |
transpose()
Blocking version of
transposeAsync() |
PgxGraph |
transpose(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.util.Map<java.lang.String,java.lang.String> edgeLabelMapping, PgxGraph.Mode mode, java.lang.String newGraphName)
Blocking version of
transposeAsync(Collection, Collection, Map, Mode, String) |
PgxGraph |
transpose(PgxGraph.Mode mode)
Blocking version of
transposeAsync(Mode) |
PgxGraph |
transpose(PgxGraph.Mode mode, java.lang.String newGraphName)
Blocking version of
transposeAsync(Mode, String) |
PgxGraph |
transpose(java.lang.String newGraphName)
Blocking version of
transposeAsync(String) |
PgxFuture<PgxGraph> |
transposeAsync()
Convenience method around
transposeAsync(String) passing null as graphName |
PgxFuture<PgxGraph> |
transposeAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.util.Map<java.lang.String,java.lang.String> edgeLabelMapping, PgxGraph.Mode mode, java.lang.String newGraphName)
Creates a transpose of this graph.
|
PgxFuture<PgxGraph> |
transposeAsync(PgxGraph.Mode mode)
Convenience method around
transposeAsync(Mode, String) passing null as graphName |
PgxFuture<PgxGraph> |
transposeAsync(PgxGraph.Mode mode, java.lang.String newGraphName)
Convenience method around
transposeAsync(Collection, Collection, Map, Mode, String) Passing Collection(vertexProps) as |
PgxFuture<PgxGraph> |
transposeAsync(java.lang.String newGraphName)
|
PgxGraph |
undirect()
Blocking version of
undirectAsync() . |
PgxGraph |
undirect(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName)
Blocking version of
undirectAsync(Collection, Collection, MultiEdges, SelfEdges, Mode, String) . |
PgxGraph |
undirect(oracle.pgx.common.mutations.MutationStrategy mutationStrategy)
Blocking version of
undirectAsync(MutationStrategy) |
PgxGraph |
undirect(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.Mode mode, java.lang.String newGraphName)
Blocking version of
undirectAsync(MultiEdges, SelfEdges, Mode, String) . |
PgxGraph |
undirect(java.lang.String newGraphName)
Blocking version of
undirectAsync(String) . |
PgxFuture<PgxGraph> |
undirectAsync()
Convenience method around
undirectAsync(String) passing null as graphName |
PgxFuture<PgxGraph> |
undirectAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.Mode mode, java.lang.String newGraphName)
Convenience method to create for
undirectAsync(MutationStrategy) . |
PgxFuture<PgxGraph> |
undirectAsync(oracle.pgx.common.mutations.MutationStrategy mutationStrategy)
Create an undirected version of a graph.
|
PgxFuture<PgxGraph> |
undirectAsync(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.Mode mode, java.lang.String newGraphName)
Convenience method for
undirectAsync(Collection, Collection, MultiEdges, SelfEdges, Mode, String) Passing Collection(vertexProps) as |
PgxFuture<PgxGraph> |
undirectAsync(java.lang.String newGraphName)
Convenience method around
undirectAsync(MultiEdges, SelfEdges, Mode, String) Passing StrategyType as |
equals, hashCode
close, destroy, destroyAsync
public BipartiteGraph bipartiteSubGraphFromInDegree() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
bipartiteSubGraphFromInDegreeAsync()
. Calls bipartiteSubGraphFromInDegreeAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public BipartiteGraph bipartiteSubGraphFromInDegree(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
bipartiteSubGraphFromInDegreeAsync(Collection, Collection, String)
. Calls bipartiteSubGraphFromInDegreeAsync(Collection, Collection, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public BipartiteGraph bipartiteSubGraphFromInDegree(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName, java.lang.String isLeftPropName, boolean inPlace) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
bipartiteSubGraphFromInDegreeAsync(Collection, Collection, String, String, boolean)
. Calls bipartiteSubGraphFromInDegreeAsync(Collection, Collection, String, String, boolean)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public BipartiteGraph bipartiteSubGraphFromInDegree(java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
bipartiteSubGraphFromInDegreeAsync(String)
. Calls bipartiteSubGraphFromInDegreeAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<BipartiteGraph> bipartiteSubGraphFromInDegreeAsync()
public PgxFuture<BipartiteGraph> bipartiteSubGraphFromInDegreeAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName)
vertexProps
- vertex properties belonging to graph specified by graph to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties belonging to graph specified by graph to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.newGraphName
- name of the new graph. If null, a name will be generated.public PgxFuture<BipartiteGraph> bipartiteSubGraphFromInDegreeAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName, java.lang.String isLeftPropName, boolean inPlace)
vertexProps
- vertex properties belonging to graph specified by graph to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties belonging to graph specified by graph to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.newGraphName
- name of the new graph. If null, a name will be generated.isLeftPropName
- name of the boolean isLeft vertex property of the new graph. f null, a name will be generated.inPlace
- whether to create a new copy (false) or overwrite this graph (true)public PgxFuture<BipartiteGraph> bipartiteSubGraphFromInDegreeAsync(java.lang.String newGraphName)
newGraphName
- name of the new graph. If null, a name will be generated.public BipartiteGraph bipartiteSubGraphFromLeftSet(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
bipartiteSubGraphFromLeftSetAsync(Collection, Collection, VertexSet, String)
. Calls bipartiteSubGraphFromLeftSetAsync(Collection, Collection, VertexSet, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public BipartiteGraph bipartiteSubGraphFromLeftSet(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, java.lang.String newGraphName, java.lang.String isLeftPropName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
bipartiteSubGraphFromLeftSetAsync(Collection, Collection, VertexSet, String, String)
. Calls bipartiteSubGraphFromLeftSetAsync(Collection, Collection, VertexSet, String, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public BipartiteGraph bipartiteSubGraphFromLeftSet(VertexSet<?> vertexSet) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
bipartiteSubGraphFromLeftSetAsync(VertexSet)
. Calls bipartiteSubGraphFromLeftSetAsync(VertexSet)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public BipartiteGraph bipartiteSubGraphFromLeftSet(VertexSet<?> vertexSet, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
bipartiteSubGraphFromLeftSetAsync(VertexSet, String)
. Calls bipartiteSubGraphFromLeftSetAsync(VertexSet, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<BipartiteGraph> bipartiteSubGraphFromLeftSetAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, java.lang.String newGraphName)
vertexProps
- vertex properties belonging to graph specified by graph to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties belonging to graph specified by graph to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.vertexSet
- vertex set representing the left sidenewGraphName
- name of the new graph. If null, a name will be generated.public PgxFuture<BipartiteGraph> bipartiteSubGraphFromLeftSetAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, java.lang.String newGraphName, java.lang.String isLeftPropName)
vertexProps
- vertex properties belonging to graph specified by graph to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties belonging to graph specified by graph to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.vertexSet
- vertex set representing the left sidenewGraphName
- name of the new graph. If null, a name will be generated.isLeftPropName
- name of the boolean isLeft vertex property of the new graph. f null, a name will be generated.public PgxFuture<BipartiteGraph> bipartiteSubGraphFromLeftSetAsync(VertexSet<?> vertexSet)
Convenience method around bipartiteSubGraphFromLeftSetAsync(Collection, Collection, VertexSet, String, String)
passing vertexProps as VertexProperty.ALL
newGraphName, edgeProps as EdgeProperty.ALL
and isLeftPropName as null
vertexSet
- vertex set representing the left sidepublic PgxFuture<BipartiteGraph> bipartiteSubGraphFromLeftSetAsync(VertexSet<?> vertexSet, java.lang.String newGraphName)
Convenience method around bipartiteSubGraphFromLeftSetAsync(Collection, Collection, VertexSet, String, String)
passing newGraphName and isLeftPropName as null
vertexSet
- vertex set representing the left sidenewGraphName
- name of the new graphpublic PgxGraph clone()
cloneAsync()
. Calls cloneAsync()
and waits for the returned PgxFuture
to complete.clone
in class java.lang.Object
java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph clone(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
cloneAsync()
. Calls cloneAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph clone(java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
cloneAsync(String)
. Calls cloneAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> cloneAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName)
vertexProps
- vertex properties belonging to graph specified by graph to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties belonging to graph specified by graph to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.newGraphName
- name of the new graph. If null, a name will be generated.public PgxFuture<PgxGraph> cloneAsync(java.lang.String newGraphName)
cloneAsync(Collection, Collection, String)
VertexProperty.ALL
EdgeProperty.ALL
newGraphName
- name of the new graph. If null, a name will be generated.public <E> EdgeProperty<PgxVect<E>> combineEdgePropertiesIntoVectorProperty(java.util.List<EdgeProperty<E>> edgePropertyList) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
combineEdgePropertiesIntoVectorPropertyAsync(List)
Calls combineEdgePropertiesIntoVectorPropertyAsync(List)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E> EdgeProperty<PgxVect<E>> combineEdgePropertiesIntoVectorProperty(java.util.List<EdgeProperty<E>> edgePropertyList, java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
combineEdgePropertiesIntoVectorPropertyAsync(List, String)
Calls combineEdgePropertiesIntoVectorPropertyAsync(List, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E> PgxFuture<EdgeProperty<PgxVect<E>>> combineEdgePropertiesIntoVectorPropertyAsync(java.util.List<EdgeProperty<E>> edgePropertyList)
E
- edge property typeedgePropertyList
- list of scalar edge propertiescreateEdgeProperty(PropertyType)
public <E> PgxFuture<EdgeProperty<PgxVect<E>>> combineEdgePropertiesIntoVectorPropertyAsync(java.util.List<EdgeProperty<E>> edgePropertyList, java.lang.String name)
E
- edge property typeedgePropertyList
- list of scalar edge propertiesname
- name for the vector property. If not null
, vector property will be named <name>. If that results in a name conflict, the returned future will complete exceptionally.createEdgeProperty(PropertyType)
public <ID,V> VertexProperty<ID,PgxVect<V>> combineVertexPropertiesIntoVectorProperty(java.util.List<VertexProperty<ID,V>> vertexPropertyList) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
combineVertexPropertiesIntoVectorPropertyAsync(List)
Calls combineVertexPropertiesIntoVectorPropertyAsync(List)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID,V> VertexProperty<ID,PgxVect<V>> combineVertexPropertiesIntoVectorProperty(java.util.List<VertexProperty<ID,V>> vertexPropertyList, java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
combineVertexPropertiesIntoVectorPropertyAsync(List, String)
Calls combineVertexPropertiesIntoVectorPropertyAsync(List, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> combineVertexPropertiesIntoVectorPropertyAsync(java.util.List<VertexProperty<ID,V>> vertexPropertyList)
ID
- property typeV
- vector property typevertexPropertyList
- list of scalar vertex propertiescreateVertexProperty(PropertyType)
public <ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> combineVertexPropertiesIntoVectorPropertyAsync(java.util.List<VertexProperty<ID,V>> vertexPropertyList, java.lang.String name)
ID
- property typeV
- vector property typevertexPropertyList
- list of scalar vertex propertiesname
- name for the vector property. If not null
, vector property will be named <name>. If that results in a name conflict, the returned future will complete exceptionally.createVertexProperty(PropertyType)
public <ID extends java.lang.Comparable<ID>> AllPaths<ID> createAllPaths(PgxVertex<ID> src, EdgeProperty<java.lang.Double> cost, VertexProperty<ID,java.lang.Double> dist, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createAllPathsAsync(PgxVertex, EdgeProperty, VertexProperty, VertexProperty, VertexProperty)
. Calls createAllPathsAsync(PgxVertex, EdgeProperty, VertexProperty, VertexProperty, VertexProperty)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID> PgxFuture<AllPaths<ID>> createAllPathsAsync(PgxVertex<ID> src, EdgeProperty<java.lang.Double> cost, VertexProperty<ID,java.lang.Double> dist, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge)
AllPaths
object representing all the shortest paths from a single source to all the possible destinations (shortest regarding the given edge costs).src
- source vertexcost
- property holding the edge costs. If null
, the resulting cost will equal the hop distance.parent
- property holding the parent vertices of all the shortest paths. For example, if the source vertex is A and the shortest path to C is A -> B -> C, then then parent[C] -> B and parent[B] -> A.parentEdge
- property holding the parent edges for each vertex shortest pathAllPaths
object.public <ID extends java.lang.Comparable<ID>> GraphChangeSet<ID> createChangeSet()
Note: This is currently not supported for undirected graphs.
public <ID> Partition<ID> createComponents(VertexProperty<ID,java.lang.Long> components, long numComponents) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createComponentsAsync(VertexProperty, long)
. Calls createComponentsAsync(VertexProperty, long)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID> PgxFuture<Partition<ID>> createComponentsAsync(VertexProperty<ID,java.lang.Long> components, long numComponents)
Partition
object holding a collection of vertex sets, each representing a component.components
- property mapping each vertex to its component ID. Note that only component IDs in the range of [0..numComponents-1] are allowed. The returned future will complete exceptionally with an IllegalArgumentException
if an invalid component ID is encountered. Gaps are supported: certain IDs not being associated with any vertices will yield to empty components.numComponents
- how many different components the components property containsPartition
object.public <V> EdgeProperty<V> createEdgeProperty(PropertyType type) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createEdgePropertyAsync(PropertyType)
. Calls createEdgePropertyAsync(PropertyType)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <V> EdgeProperty<V> createEdgeProperty(PropertyType type, int dimension, java.lang.String name, boolean hardName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createEdgePropertyAsync(PropertyType, int, String, boolean)
. Calls createEdgePropertyAsync(PropertyType, int, String, boolean)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <V> EdgeProperty<V> createEdgeProperty(PropertyType type, java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createEdgePropertyAsync(PropertyType, String)
. Calls createEdgePropertyAsync(PropertyType, String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <V> PgxFuture<EdgeProperty<V>> createEdgePropertyAsync(PropertyType type)
type
- type of property to createpublic <V> PgxFuture<EdgeProperty<V>> createEdgePropertyAsync(PropertyType type, java.lang.String name)
type
- type of property to createname
- of property to be createdpublic EdgeSequence createEdgeSequence() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createEdgeSequenceAsync()
. Calls createEdgeSequenceAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public EdgeSequence createEdgeSequence(java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createEdgeSequenceAsync(String)
. Calls createEdgeSequenceAsync(String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<EdgeSequence> createEdgeSequenceAsync()
public PgxFuture<EdgeSequence> createEdgeSequenceAsync(java.lang.String name)
name
- name of the edge sequence to be createdpublic EdgeSet createEdgeSet() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createEdgeSetAsync()
. Calls createEdgeSetAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public EdgeSet createEdgeSet(java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createEdgeSetAsync(String)
. Calls createEdgeSetAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<EdgeSet> createEdgeSetAsync()
public PgxFuture<EdgeSet> createEdgeSetAsync(java.lang.String name)
name
- name of the edge set to be createdpublic <V> EdgeProperty<PgxVect<V>> createEdgeVectorProperty(PropertyType type, int dimension) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createEdgeVectorPropertyAsync(PropertyType, int)
. Calls createEdgeVectorPropertyAsync(PropertyType, int)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <V> EdgeProperty<PgxVect<V>> createEdgeVectorProperty(PropertyType type, int dimension, java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createEdgeVectorPropertyAsync(PropertyType, int, String)
. Calls createEdgeVectorPropertyAsync(PropertyType, int, String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <V> PgxFuture<EdgeProperty<PgxVect<V>>> createEdgeVectorPropertyAsync(PropertyType type, int dimension)
type
- type of vector property to createdimension
- of vector property to be createdpublic <V> PgxFuture<EdgeProperty<PgxVect<V>>> createEdgeVectorPropertyAsync(PropertyType type, int dimension, java.lang.String name)
type
- type of vector property to createdimension
- of vector property to be createdname
- of vector property to be createdpublic <K,V> PgxMap<K,V> createMap(PropertyType keyType, PropertyType valType) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createMapAsync(PropertyType, PropertyType)
. Calls createMapAsync(PropertyType, PropertyType)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <K,V> PgxMap<K,V> createMap(PropertyType keyType, PropertyType valType, java.lang.String mapName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createMapAsync(PropertyType, PropertyType, String)
. Calls createMapAsync(PropertyType, PropertyType, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <K,V> PgxFuture<PgxMap<K,V>> createMapAsync(PropertyType keyType, PropertyType valType)
keyType
- Property type of the keys that are going to be stored inside the mapvalType
- Property type of the values that are going to be stored inside the mappublic <K,V> PgxFuture<PgxMap<K,V>> createMapAsync(PropertyType keyType, PropertyType valType, java.lang.String mapName)
keyType
- Property type of the keys that are going to be stored inside the mapvalType
- Property type of the values that are going to be stored inside the mapmapName
- how the map should be namedpublic MergingStrategyBuilder createMergingStrategyBuilder() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
MergingStrategyBuilder
that can be used to build a new MutationStrategy
to simplify this graph.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID> PgxPath<ID> createPath(PgxVertex<ID> src, PgxVertex<ID> dst, EdgeProperty<java.lang.Double> cost, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createPathAsync(PgxVertex, PgxVertex, EdgeProperty, VertexProperty, VertexProperty)
. Calls createPathAsync(PgxVertex, PgxVertex, EdgeProperty, VertexProperty, VertexProperty)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID> PgxFuture<PgxPath<ID>> createPathAsync(PgxVertex<ID> src, PgxVertex<ID> dst, EdgeProperty<java.lang.Double> cost, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge)
PgxPath
object representing the shortest path from one source to one destination (shortest regarding the given edge costs). If there are multiple shortest paths, an arbitrary one will be returned.src
- source vertex of the pathdst
- destination vertex of the pathcost
- property holding the edge costs. If null
, the resulting cost will equal the hop distance.parent
- property holding the parent vertices for each vertex of the shortest path. For example, if the shortest path is A -> B -> C, then parent[C] -> B and parent[B] -> A.parentEdge
- property holding the parent edges for each vertex of the shortest pathPgxPath
object.public PickingStrategyBuilder createPickingStrategyBuilder() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
PickingStrategyBuilder
that can be used to build a new PickingStrategy
to simplify this graph.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <T> Scalar<T> createScalar(PropertyType type) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createScalarAsync(PropertyType)
. Calls createScalarAsync(PropertyType)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <T> Scalar<T> createScalar(PropertyType type, java.lang.String newScalarName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createScalarAsync(PropertyType, String)
. Calls createScalarAsync(PropertyType, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <T> PgxFuture<Scalar<T>> createScalarAsync(PropertyType type)
type
- the Property Typepublic <T> PgxFuture<Scalar<T>> createScalarAsync(PropertyType type, java.lang.String newScalarName)
type
- the type of scalarnewScalarName
- name of the scalar to be createdpublic <T> Scalar<PgxVect<T>> createVectorScalar(PropertyType type, int dimension) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVectorScalarAsync(PropertyType, int)
. Calls createVectorScalarAsync(PropertyType, int)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <T> Scalar<PgxVect<T>> createVectorScalar(PropertyType type, int dimension, java.lang.String newScalarName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVectorScalarAsync(PropertyType, int, String)
. Calls createVectorScalarAsync(PropertyType, int, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <T> PgxFuture<Scalar<PgxVect<T>>> createVectorScalarAsync(PropertyType type, int dimension)
type
- the type of vector scalardimension
- of vector scalar to be createdpublic <T> PgxFuture<Scalar<PgxVect<T>>> createVectorScalarAsync(PropertyType type, int dimension, java.lang.String newScalarName)
type
- the type of vector scalardimension
- of vector scalar to be creatednewScalarName
- name of the vector scalar to be createdpublic <ID,V> VertexProperty<ID,V> createVertexProperty(PropertyType type) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVertexPropertyAsync(PropertyType)
. Calls createVertexPropertyAsync(PropertyType)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID,V> VertexProperty<ID,V> createVertexProperty(PropertyType type, int dimension, java.lang.String name, boolean hardName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVertexPropertyAsync(PropertyType, int, String, boolean)
. Calls createVertexPropertyAsync(PropertyType, int, String, boolean)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID,V> VertexProperty<ID,V> createVertexProperty(PropertyType type, java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVertexPropertyAsync(PropertyType, String)
. Calls createVertexPropertyAsync(PropertyType, String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID,V> PgxFuture<VertexProperty<ID,V>> createVertexPropertyAsync(PropertyType type)
type
- type of the property to createpublic <ID,V> PgxFuture<VertexProperty<ID,V>> createVertexPropertyAsync(PropertyType type, java.lang.String name)
type
- type of property to createname
- of property to be createdpublic <E> VertexSequence<E> createVertexSequence() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVertexSequenceAsync()
. Calls createVertexSequenceAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E> VertexSequence<E> createVertexSequence(java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVertexSequenceAsync(String)
. Calls createVertexSequenceAsync(String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E> PgxFuture<VertexSequence<E>> createVertexSequenceAsync()
public <E> PgxFuture<VertexSequence<E>> createVertexSequenceAsync(java.lang.String name)
name
- the name of the collection to be createdpublic <E> VertexSet<E> createVertexSet() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVertexSetAsync()
. Calls createVertexSetAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E> VertexSet<E> createVertexSet(java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVertexSetAsync(String)
. Calls createVertexSetAsync(String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E> PgxFuture<VertexSet<E>> createVertexSetAsync()
public <E> PgxFuture<VertexSet<E>> createVertexSetAsync(java.lang.String name)
name
- name of the vertex set to be createdpublic <ID,V> VertexProperty<ID,PgxVect<V>> createVertexVectorProperty(PropertyType type, int dimension) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVertexVectorPropertyAsync(PropertyType, int)
. Calls createVertexVectorPropertyAsync(PropertyType, int)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID,V> VertexProperty<ID,PgxVect<V>> createVertexVectorProperty(PropertyType type, int dimension, java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
createVertexVectorPropertyAsync(PropertyType, int, String)
. Calls createVertexVectorPropertyAsync(PropertyType, int, String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> createVertexVectorPropertyAsync(PropertyType type, int dimension)
type
- type of the vector property to createdimension
- of vector property to be createdpublic <ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> createVertexVectorPropertyAsync(PropertyType type, int dimension, java.lang.String name)
type
- type of vector property to createdimension
- of vector property to be createdname
- of vector property to be createdpublic PgxGraph filter(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, GraphFilter graphFilter, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
filterAsync(Collection, Collection, GraphFilter, String)
. Calls filterAsync(Collection, Collection, GraphFilter, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph filter(GraphFilter graphFilter) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
filterAsync(GraphFilter)
. Calls filterAsync(GraphFilter)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph filter(GraphFilter graphFilter, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
filterAsync(GraphFilter, String)
. Calls filterAsync(GraphFilter, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> filterAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, GraphFilter graphFilter, java.lang.String newGraphName)
vertexProps
- vertex properties belonging to graph specified by graph to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties belonging to graph specified by graph to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.graphFilter
- GraphFilter object representing a filter expression that is applied to create the subgraphnewGraphName
- name of the new graph. If null, a name will be generated.public PgxFuture<PgxGraph> filterAsync(GraphFilter graphFilter)
Convenience method around filterAsync(GraphFilter, String)
Passing
null
graphFilter
- GraphFilter object representing a filter expression that is applied to create the subgraphpublic PgxFuture<PgxGraph> filterAsync(GraphFilter graphFilter, java.lang.String newGraphName)
Convenience method around filterAsync(Collection, Collection, GraphFilter, String)
Passing
VertexProperty.ALL
EdgeProperty.ALL
graphFilter
- GraphFilter object representing a filter expression that is applied to create the subgraphnewGraphName
- name of the new graph. If null, a name will be generated.public GraphConfig getConfig()
null
if graph was not created from a datasource (isTransient()
is true
).public long getCreationRequestTimestamp()
public long getCreationTimestamp()
public java.lang.String getDataSourceVersion()
null
if graph was not created from a datasource ( isTransient()
is true
).public PgxEdge getEdge(long id) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getEdgeAsync(long)
Calls getEdgeAsync(long)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxEdge> getEdgeAsync(long id)
PgxEdge
of this graph by ID.id
- the ID of the edgePgxEdge
objectpublic EdgeLabel getEdgeLabel() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getEdgeLabelAsync()
. Calls getEdgeLabelAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<EdgeLabel> getEdgeLabelAsync()
public java.util.Set<EdgeProperty<?>> getEdgeProperties() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getEdgePropertiesAsync()
. Calls getEdgePropertiesAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.util.Set<EdgeProperty<?>>> getEdgePropertiesAsync()
public <V> EdgeProperty<V> getEdgeProperty(java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getEdgePropertyAsync(String)
. Calls getEdgePropertyAsync(String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <V> PgxFuture<EdgeProperty<V>> getEdgePropertyAsync(java.lang.String name)
name
- the name of the edge propertynull
if no such property existsjava.lang.NullPointerException
- if the passed name is nullpublic EdgeSet getEdges() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public EdgeSet getEdges(EdgeFilter filter) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
getEdges(EdgeFilter)
. Calls getEdges(EdgeFilter)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<EdgeSet> getEdgesAsync()
public <E> PgxFuture<EdgeSet> getEdgesAsync(EdgeFilter filter)
filter
- the edge filter expression used to create the edge setpublic long getMemoryMb()
public java.lang.String getName()
getName
in class PgxManagedObject
public long getNumEdges()
public long getNumVertices()
public ServerInstance getPgxInstance()
public PgxSession getSession()
public <ID> PgxVertex<ID> getVertex(ID id) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getVertexAsync(Object)
. Calls getVertexAsync(Object)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID> PgxFuture<PgxVertex<ID>> getVertexAsync(ID id)
PgxVertex
of this graph by ID.id
- the ID of the vertexPgxVertex
objectpublic IdType getVertexIdType()
public <ID> VertexLabels<ID> getVertexLabels() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getVertexLabelsAsync()
. Calls getVertexLabelsAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID> PgxFuture<VertexLabels<ID>> getVertexLabelsAsync()
public java.util.Set<VertexProperty<?,?>> getVertexProperties() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getVertexPropertiesAsync()
. Calls getVertexPropertiesAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.util.Set<VertexProperty<?,?>>> getVertexPropertiesAsync()
public <ID,V> VertexProperty<ID,V> getVertexProperty(java.lang.String name) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
getVertexPropertyAsync(String)
. Calls getVertexPropertyAsync(String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID,V> PgxFuture<VertexProperty<ID,V>> getVertexPropertyAsync(java.lang.String name)
name
- the name of the vertex propertynull
if no such property existsjava.lang.NullPointerException
- if the passed name is nullpublic <E> VertexSet<E> getVertices() throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
getVerticesAsync()
. Calls getVerticesAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E> VertexSet<E> getVertices(VertexFilter filter) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
getVerticesAsync(VertexFilter)
. Calls getVerticesAsync(VertexFilter)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E> VertexSet<E> getVertices(VertexFilter filter, java.lang.String name) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
getVerticesAsync(VertexFilter,String)
. Calls getVerticesAsync(VertexFilter,String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E> PgxFuture<VertexSet<E>> getVerticesAsync()
public <E> PgxFuture<VertexSet<E>> getVerticesAsync(VertexFilter filter)
filter
- the vertex filter expression used to create the vertex setpublic <E> PgxFuture<VertexSet<E>> getVerticesAsync(VertexFilter filter, java.lang.String name)
filter
- the vertex filter expression used to create the vertex setname
- the name of the collection to be created. If NULL
, a name will be generated.public boolean hasEdge(long id) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
hasEdgeAsync(long)
Calls hasEdgeAsync(long)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Boolean> hasEdgeAsync(long id)
id
- the ID of the edgepublic <ID> boolean hasVertex(ID id) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
hasVertexAsync(Object)
. Calls hasVertexAsync(Object)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID> PgxFuture<java.lang.Boolean> hasVertexAsync(ID id)
id
- the ID of the vertexpublic java.lang.Boolean isBipartiteGraph(VertexProperty<?,java.lang.Boolean> isLeft) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
isBipartiteGraphAsync(VertexProperty)
. Calls isBipartiteGraphAsync(VertexProperty)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID> PgxFuture<java.lang.Boolean> isBipartiteGraphAsync(VertexProperty<ID,java.lang.Boolean> isLeft)
isLeft
- boolean vertex property that - if the method returns true - will contain for each node whether it is on the 'left' side of the bipartite graph. If the method returns false, the content is undefined.public boolean isDirected()
public boolean isFresh() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
isFreshAsync()
. Calls isFreshAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<java.lang.Boolean> isFreshAsync()
If the given graph is transient (private, session-bound), it is always considered fresh.
public boolean isTransient()
true
if this graph is transient (session-bound, private), false
otherwise.public <ID> PgxVertex<ID> pickRandomVertex() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
pickRandomVertexAsync()
. Calls pickRandomVertexAsync()
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID> PgxFuture<PgxVertex<ID>> pickRandomVertexAsync()
public PgqlResultSet queryPgql(java.lang.String pgqlString) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
queryPgql(String)
. Calls queryPgql(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgqlResultSet queryPgql(java.lang.String pgqlString, PatternMatchingSemantic patternMatchingSemantic) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
queryPgql(String, PatternMatchingSemantic)
. Calls queryPgqlAsync(String, PatternMatchingSemantic)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgqlResultSet> queryPgqlAsync(java.lang.String pgqlString)
pgqlString
- query string in PGQLpublic PgxFuture<PgqlResultSet> queryPgqlAsync(java.lang.String pgqlString, PatternMatchingSemantic patternMatchingSemantic)
pgqlString
- query string in PGQLpatternMatchingSemantic
- pattern matching semantic; either graph isomorphism (PatternMatchingSemantic.ISOMORPHISM
) or graph homomorphism (PatternMatchingSemantic.HOMOMORPHISM
)public PgxGraph simplify() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
simplifyAsync()
. Calls simplifyAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph simplify(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
simplifyAsync(Collection, Collection, MultiEdges, SelfEdges, TrivialVertices, Mode, String)
. Calls simplifyAsync(Collection, Collection, MultiEdges, SelfEdges, TrivialVertices, Mode, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph simplify(oracle.pgx.common.mutations.MutationStrategy mutationStrategy) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public PgxGraph simplify(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
simplifyAsync(MultiEdges, SelfEdges, TrivialVertices, Mode, String)
. Calls simplifyAsync(MultiEdges, SelfEdges, TrivialVertices, Mode, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph simplify(java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
simplifyAsync(String)
. Calls simplifyAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> simplifyAsync()
simplifyAsync(String)
passing null as graphNamepublic PgxFuture<PgxGraph> simplifyAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName)
vertexProps
- vertex properties belonging to graph specified by graph to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties belonging to graph specified by graph to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.multiEdges
- defines if multi-edges should be kept in the result. Constants PgxGraph.MultiEdges.KEEP_MULTI_EDGES
or PgxGraph.MultiEdges.REMOVE_MULTI_EDGES
can be usedselfEdges
- defines if self-edges should be kept in the result. Constants PgxGraph.SelfEdges.KEEP_SELF_EDGES
or PgxGraph.SelfEdges.REMOVE_SELF_EDGES
can be used.trivialVertices
- defines if isolated nodes should be kept in the result. Constants PgxGraph.TrivialVertices.KEEP_TRIVIAL_VERTICES
or PgxGraph.TrivialVertices.REMOVE_TRIVIAL_VERTICES
can be usedmode
- defines if a copy of the graph should be created, otherwise graph is mutated in place. Constants PgxGraph.Mode.MUTATE_IN_PLACE
or PgxGraph.Mode.CREATE_COPY
can be usednewGraphName
- name of the new graph (only relevant if mode == PgxGraph.Mode.CREATE_COPY
). If null, a name will be generated.public PgxFuture<PgxGraph> simplifyAsync(oracle.pgx.common.mutations.MutationStrategy mutationStrategy)
public PgxFuture<PgxGraph> simplifyAsync(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName)
simplifyAsync(Collection, Collection, MultiEdges, SelfEdges, TrivialVertices, Mode, String)
VertexProperty.ALL
EdgeProperty.ALL
Create a simplified version of a graph. Note that the returned graph and properties are transient and therefore session bound. They can be explicitly destroyed and get automatically freed once the session dies.
multiEdges
- defines if multi-edges should be kept in the result. Constants PgxGraph.MultiEdges.KEEP_MULTI_EDGES
or PgxGraph.MultiEdges.REMOVE_MULTI_EDGES
can be usedselfEdges
- defines if self-edges should be kept in the result. Constants PgxGraph.SelfEdges.KEEP_SELF_EDGES
or PgxGraph.SelfEdges.REMOVE_SELF_EDGES
can be used.trivialVertices
- defines if isolated nodes should be kept in the result. Constants PgxGraph.TrivialVertices.KEEP_TRIVIAL_VERTICES
or PgxGraph.TrivialVertices.REMOVE_TRIVIAL_VERTICES
can be usedmode
- defines if a copy of the graph should be created, otherwise graph is mutated in place. Constants PgxGraph.Mode.MUTATE_IN_PLACE
or PgxGraph.Mode.CREATE_COPY
can be usednewGraphName
- name of the new graph (only relevant if mode == PgxGraph.Mode.CREATE_COPY
). If null, a name will be generated.public PgxFuture<PgxGraph> simplifyAsync(java.lang.String newGraphName)
simplifyAsync(MultiEdges, SelfEdges, TrivialVertices, Mode, String)
StrategyType.REMOVE_MULTI_EDGES
SelfEdges.REMOVE_SELF_EDGES
TrivialVertices.REMOVE_TRIVIAL_VERTICES
Mode.CREATE_COPY
Create a simplified version of a graph. Note that the returned graph and properties are transient and therefore session bound. They can be explicitly destroyed and get automatically freed once the session dies.
newGraphName
- name of the new graph, if empty string, a name will be generated.public PgxGraph sortByDegree() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
sortByDegreeAsync()
. Calls sortByDegreeAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph sortByDegree(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.SortOrder sortOrder, PgxGraph.Degree degree, PgxGraph.Mode mode, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
sortByDegreeAsync(Collection, Collection, SortOrder, Degree, Mode, String)
. Calls sortByDegreeAsync(Collection, Collection, SortOrder, Degree, Mode, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph sortByDegree(PgxGraph.SortOrder sortOrder, PgxGraph.Degree degree, PgxGraph.Mode mode, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
sortByDegreeAsync(SortOrder, Degree, Mode, String)
. Calls sortByDegreeAsync(SortOrder, Degree, Mode, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph sortByDegree(java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
sortByDegreeAsync(String)
. Calls sortByDegreeAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> sortByDegreeAsync()
sortByDegree(String)
Passing newGraphName as null
public PgxFuture<PgxGraph> sortByDegreeAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.SortOrder sortOrder, PgxGraph.Degree degree, PgxGraph.Mode mode, java.lang.String newGraphName)
vertexProps
- vertex properties belonging to graph specified by graph to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties belonging to graph specified by graph to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.sortOrder
- sort order. Constants PgxGraph.SortOrder.ASCENDING
or PgxGraph.SortOrder.DESCENDING
should be useddegree
- degree sorting mode. Constants PgxGraph.Degree.OUT
or PgxGraph.Degree.IN
should be usedmode
- it specifies if the graph should be mutated in place or a new one should be created. Constants PgxGraph.Mode.MUTATE_IN_PLACE
or PgxGraph.Mode.CREATE_COPY
should be usednewGraphName
- name of the new graph (only relevant if a new copy is being created). If null, a name will be generated.public PgxFuture<PgxGraph> sortByDegreeAsync(PgxGraph.SortOrder sortOrder, PgxGraph.Degree degree, PgxGraph.Mode mode, java.lang.String newGraphName)
sortByDegreeAsync(Collection, Collection, SortOrder, Degree, Mode, String)
Passing
VertexProperty.ALL
EdgeProperty.ALL
sortOrder
- sort order. Constants PgxGraph.SortOrder.ASCENDING
or PgxGraph.SortOrder.DESCENDING
should be useddegree
- degree sorting mode. Constants PgxGraph.Degree.OUT
or PgxGraph.Degree.IN
should be usedmode
- it specifies if the graph should be mutated in place or a new one should be created. Constants PgxGraph.Mode.MUTATE_IN_PLACE
or PgxGraph.Mode.CREATE_COPY
should be usednewGraphName
- name of the new graph (only relevant if a new copy is being created). If null, a name will be generated.public PgxFuture<PgxGraph> sortByDegreeAsync(java.lang.String newGraphName)
sortByDegree(SortOrder, Degree, Mode, String)
Passing
SortOrder.DESCENDING
Degree.IN
Mode.CREATE_COPY
newGraphName
- name of the new graph (only relevant if a new copy is being created). If null, a name will be generated.public PgxGraph sparsify(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, double e, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
sparsifyAsync(Collection, Collection, double, String)
. Calls sparsifyAsync(Collection, Collection, double, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph sparsify(double e) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
sparsifyAsync(double)
. Calls sparsifyAsync(double)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph sparsify(double e, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
sparsifyAsync(double, String)
. Calls sparsifyAsync(double, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> sparsifyAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, double e, java.lang.String newGraphName)
vertexProps
- vertex properties belonging to graph specified by graph to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties belonging to graph specified by graph to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.e
- the sparsification coefficientnewGraphName
- name of the new graph. If null, a name will be generated.public PgxFuture<PgxGraph> sparsifyAsync(double e)
Convenience method around sparsify(double, String)
Passing
null
e
- the sparsification coefficientpublic PgxFuture<PgxGraph> sparsifyAsync(double e, java.lang.String newGraphName)
Convenience method around sparsify(Collection, Collection, double, String)
Passing
VertexProperty.ALL
EdgeProperty.ALL
e
- the sparsification coefficient. Must be between 0.0 and 1.0.newGraphName
- name of the new graph. If null, a name will be generated.public FileGraphConfig store(Format targetFormat, java.lang.String targetPath) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(Format, String)
. Calls storeAsync(Format, String)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public FileGraphConfig store(Format targetFormat, java.lang.String targetPath, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(Format, String, boolean)
. Calls storeAsync(Format, String, boolean)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public FileGraphConfig store(Format targetFormat, java.lang.String targetPath, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(Format, String, Collection, Collection, boolean)
. Calls storeAsync(Format, String, Collection, Collection, boolean)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public GraphConfig store(GraphConfig targetConfig, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(GraphConfig, boolean)
. Calls storeAsync(GraphConfig, boolean)
and waits for returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, java.lang.String targetPath)
store(Format, String, boolean)
, setting the overwrite flag to false
.targetFormat
- the format in which to store this graph. Note that only single file formats are supported.targetPath
- the path the graph should be written to. Use schemes to write to a specific file system.public PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, java.lang.String targetPath, boolean overwrite)
storeAsync(Format, String, Collection, Collection, boolean)
, storing all vertex and edge properties and no file system attributes.targetFormat
- the format in which to store this graph. Note that only single file formats are supported.targetPath
- the path the graph should be written to. Use schemes to write to a specific file system.overwrite
- Set this flag to true
if you want to overwrite any existing file rather than getting an exception if the target path already exists.public PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, java.lang.String targetPath, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.targetPath
- the path the graph should be written to. Use schemes to write to a specific file system.vertexProps
- the collection of vertex properties to store together with the graph data. You can use VertexProperty.NONE
or VertexProperty.ALL
to indicate all or no properties.edgeProps
- the collection of edge properties to store together with the graph data. You can use EdgeProperty.NONE
or EdgeProperty.ALL
to indicate all or no properties.overwrite
- Set this flag to true
if you want to overwrite any existing file rather than getting an exception if the target path already exists.public PgxFuture<GraphConfig> storeAsync(GraphConfig targetConfig, boolean overwrite)
targetConfig
- the graph configuration describing the stored graph.overwrite
- Set this flag to true
if you want to overwrite any existing file rather than getting an exception if the target path already exists.public java.lang.String toString()
toString
in class java.lang.Object
public PgxGraph transpose() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
transposeAsync()
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public PgxGraph transpose(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.util.Map<java.lang.String,java.lang.String> edgeLabelMapping, PgxGraph.Mode mode, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
transposeAsync(Collection, Collection, Map, Mode, String)
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public PgxGraph transpose(PgxGraph.Mode mode) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
transposeAsync(Mode)
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public PgxGraph transpose(PgxGraph.Mode mode, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
transposeAsync(Mode, String)
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public PgxGraph transpose(java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
transposeAsync(String)
java.util.concurrent.ExecutionException
java.lang.InterruptedException
public PgxFuture<PgxGraph> transposeAsync()
transposeAsync(String)
passing null as graphNamepublic PgxFuture<PgxGraph> transposeAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.util.Map<java.lang.String,java.lang.String> edgeLabelMapping, PgxGraph.Mode mode, java.lang.String newGraphName)
isDirected()
returns false
), this operation has no effect and will either return a copy or act as identity function depending on the mode
parameter.vertexProps
- vertex properties to be transformed as well. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties to be transformed as well. Constants EdgeProperty.ALL
or EdgeProperty.NONE
can be used.edgeLabelMapping
- can be used to rename edge labels. For example, an edge (John,Mary) labeled "fatherOf" can be transformed to be labeled "hasFather" on the transpose graph's edge (Mary,John) by passing in a map like Collections.singletonMap("fatherOf", "hasFather")
. If the given map is an empty map, the transpose graph will have the same edge labels as this graph. If the given map is NULL
, the transpose graph won't contain any edge labels (all labels will be removed). If any key in the given map does not exist as an edge label, it will be ignored.mode
- specifies if the graph should be mutated in place or a new one should be created. Constants PgxGraph.Mode.MUTATE_IN_PLACE
or PgxGraph.Mode.CREATE_COPY
should be usednewGraphName
- name of the new graph (only relevant if a new copy is being created). If null, a name will be generated.public PgxFuture<PgxGraph> transposeAsync(PgxGraph.Mode mode)
transposeAsync(Mode, String)
passing null as graphNamepublic PgxFuture<PgxGraph> transposeAsync(PgxGraph.Mode mode, java.lang.String newGraphName)
transposeAsync(Collection, Collection, Map, Mode, String)
Passing
VertexProperty.ALL
EdgeProperty.ALL
newGraphName
- name of the new graph (only relevant if mode == PgxGraph.Mode.CREATE_COPY
). If null, a name will be generated.public PgxFuture<PgxGraph> transposeAsync(java.lang.String newGraphName)
newGraphName
- name of the new graph (only relevant if mode == PgxGraph.Mode.CREATE_COPY
). If null, a name will be generated.public PgxGraph undirect() throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
undirectAsync()
. Calls undirectAsync()
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph undirect(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
undirectAsync(Collection, Collection, MultiEdges, SelfEdges, Mode, String)
. Calls undirectAsync(Collection, Collection, MultiEdges, SelfEdges, Mode, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph undirect(oracle.pgx.common.mutations.MutationStrategy mutationStrategy) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
undirectAsync(MutationStrategy)
mutationStrategy
-java.util.concurrent.ExecutionException
java.lang.InterruptedException
public PgxGraph undirect(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.Mode mode, java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
undirectAsync(MultiEdges, SelfEdges, Mode, String)
. Calls undirectAsync(MultiEdges, SelfEdges, Mode, String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxGraph undirect(java.lang.String newGraphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
undirectAsync(String)
. Calls undirectAsync(String)
and waits for the returned PgxFuture
to complete.java.lang.InterruptedException
- if the caller thread gets interrupted while waiting for completion.java.util.concurrent.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> undirectAsync()
undirectAsync(String)
passing null as graphNamepublic PgxFuture<PgxGraph> undirectAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.Mode mode, java.lang.String newGraphName)
undirectAsync(MutationStrategy)
.vertexProps
- vertex properties belonging to graph. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
-multiEdges
- defines if multi-edges should be kept in the result. Constants PgxGraph.MultiEdges.KEEP_MULTI_EDGES
or PgxGraph.MultiEdges.REMOVE_MULTI_EDGES
can be usedselfEdges
- defines if self-edges should be kept in the result. Constants PgxGraph.SelfEdges.KEEP_SELF_EDGES
or PgxGraph.SelfEdges.REMOVE_SELF_EDGES
can be used.mode
- defines if a copy of the graph should be created, otherwise graph is mutated in place. Constants PgxGraph.Mode.MUTATE_IN_PLACE
or PgxGraph.Mode.CREATE_COPY
can be usednewGraphName
- name of the new graph (only relevant if mode == PgxGraph.Mode.CREATE_COPY
). If null, a name will be generated.public PgxFuture<PgxGraph> undirectAsync(oracle.pgx.common.mutations.MutationStrategy mutationStrategy)
EdgeProperties are handled according to the provided MutationStrategy
.
mutationStrategy
-public PgxFuture<PgxGraph> undirectAsync(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.Mode mode, java.lang.String newGraphName)
undirectAsync(Collection, Collection, MultiEdges, SelfEdges, Mode, String)
Passing Collection(vertexProps) as VertexProperty.ALL
and Collection(edgeProps) as EdgeProperty.ALL
multiEdges
- defines if multi-edges should be kept in the result.selfEdges
- defines if self-edges should be kept in the result. Constants PgxGraph.SelfEdges.KEEP_SELF_EDGES
or PgxGraph.SelfEdges.REMOVE_SELF_EDGES
can be used.mode
- defines if a copy of the graph should be created, otherwise graph is mutated in place. Constants PgxGraph.Mode.MUTATE_IN_PLACE
or PgxGraph.Mode.CREATE_COPY
can be usednewGraphName
- name of the new graph (only relevant if mode == PgxGraph.Mode.CREATE_COPY
). If null, a name will be generated.public PgxFuture<PgxGraph> undirectAsync(java.lang.String newGraphName)
undirectAsync(MultiEdges, SelfEdges, Mode, String)
Passing
StrategyType.KEEP_MULTI_EDGES
SelfEdges.KEEP_SELF_EDGES
TrivialVertices.KEEP_TRIVIALVERTICES
Mode.CREATE_COPY
newGraphName
- name of the new graph (only relevant if mode == PgxGraph.Mode.CREATE_COPY
). If null, a name will be generated.Copyright © 2017 Oracle Corp. All Rights Reserved.