public class PgxGraph extends PgxManagedObject
Modifier and Type | Class and Description |
---|---|
static class |
PgxGraph.Degree |
static class |
PgxGraph.Direction |
static class |
PgxGraph.Mode |
static class |
PgxGraph.MultiEdges |
static class |
PgxGraph.SelfEdges |
static class |
PgxGraph.TrivialVertices |
Modifier and Type | Method and Description |
---|---|
BipartiteGraph |
bipartiteSubGraphFromLeftSet(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, String newGraphName)
Blocking version of
#bipartiteSubGraphFromLeftSetAsync() . |
BipartiteGraph |
bipartiteSubGraphFromLeftSet(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, String newGraphName, String isLeftPropName)
Blocking version of
#bipartiteSubGraphFromLeftSetAsync() . |
BipartiteGraph |
bipartiteSubGraphFromLeftSet(VertexSet<?> vertexSet)
Blocking version of
#bipartiteSubGraphFromLeftSetAsync() . |
BipartiteGraph |
bipartiteSubGraphFromLeftSet(VertexSet<?> vertexSet, String newGraphName)
Blocking version of
#bipartiteSubGraphFromLeftSetAsync() . |
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromLeftSetAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, String newGraphName)
Create a bipartite version of a graph.
|
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromLeftSetAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, String newGraphName, String isLeftPropName) |
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromLeftSetAsync(VertexSet<?> vertexSet)
Create a bipartite version of a graph.
#bipartiteSubGraphFromLeftSet(Collection, Collection, VertexSet) Passing vertexProps as VertexProperty.ALL edgeProps as EdgeProperty.ALL |
PgxFuture<BipartiteGraph> |
bipartiteSubGraphFromLeftSetAsync(VertexSet<?> vertexSet, String newGraphName)
Create a bipartite version of a graph.
|
PgxGraph |
clone()
Blocking version of
cloneAsync() . |
PgxGraph |
clone(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, String newGraphName)
Blocking version of
cloneAsync() . |
PgxGraph |
clone(String newGraphName)
Blocking version of
cloneAsync() . |
PgxFuture<PgxGraph> |
cloneAsync()
|
PgxFuture<PgxGraph> |
cloneAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, String newGraphName)
Create a copy of a graph.
|
PgxFuture<PgxGraph> |
cloneAsync(String newGraphName)
Convenience method of
cloneAsync(Collection, Collection, String) Passing Collection(vertexProperties) as VertexProperty.ALL Collection(edgeProperties) as EdgeProperty.ALL Create a copy of a graph. |
<ID extends Comparable<ID>> |
createAllPaths(PgxVertex<ID> src, EdgeProperty<Double> cost, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge)
Blocking version of
#createAllPathsAsync() . |
<ID extends Comparable<ID>> |
createAllPathsAsync(PgxVertex<ID> src, EdgeProperty<Double> cost, 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 Comparable<ID>> |
createComponents(VertexProperty<ID,Integer> components, int numComponents)
Blocking version of
#createComponentsAsync() . |
<ID extends Comparable<ID>> |
createComponentsAsync(VertexProperty<ID,Integer> components, int numComponents)
Creates a
Partition object holding a collection of vertex sets, each representing a component. |
<V extends Comparable<V>> |
createEdgeProperty(PropertyType type)
Blocking version of
#createEdgePropertyAsync() . |
<V extends Comparable<V>> |
createEdgeProperty(PropertyType type, String name)
Blocking version of
#createEdgePropertyAsync() . |
<V extends Comparable<V>> |
createEdgePropertyAsync(PropertyType type)
Creates a session-bound edge property
|
<V extends Comparable<V>> |
createEdgePropertyAsync(PropertyType type, String name)
Creates a session-bound edge property
|
EdgeSequence |
createEdgeSequence()
Blocking version of
createEdgeSequenceAsync() . |
EdgeSequence |
createEdgeSequence(String name)
Blocking version of
createEdgeSequenceAsync() . |
PgxFuture<EdgeSequence> |
createEdgeSequenceAsync()
Creates a new Edge Sequence.
|
PgxFuture<EdgeSequence> |
createEdgeSequenceAsync(String name)
Creates a new Edge Sequence.
|
EdgeSet |
createEdgeSet()
Blocking version of
createEdgeSetAsync() . |
EdgeSet |
createEdgeSet(String name)
Blocking version of
createEdgeSetAsync() . |
PgxFuture<EdgeSet> |
createEdgeSetAsync()
Creates a new Edge Set.
|
PgxFuture<EdgeSet> |
createEdgeSetAsync(String name)
Creates a new Edge Set.
|
<K extends Comparable<K>,V extends Comparable<V>> |
createMap(PropertyType keyType, PropertyType valType)
Blocking version of
#createMapAsync() . |
<K extends Comparable<K>,V extends Comparable<V>> |
createMap(PropertyType keyType, PropertyType valType, MapType mapType)
Blocking version of
#createMapAsync() . |
<K extends Comparable<K>,V extends Comparable<V>> |
createMap(PropertyType keyType, PropertyType valType, MapType mapType, String mapName)
Blocking version of
#createMapAsync() . |
<K extends Comparable<K>,V extends Comparable<V>> |
createMapAsync(PropertyType keyType, PropertyType valType)
Creates a session-bound map
|
<K extends Comparable<K>,V extends Comparable<V>> |
createMapAsync(PropertyType keyType, PropertyType valType, MapType mapType)
Creates a session-bound map
|
<K extends Comparable<K>,V extends Comparable<V>> |
createMapAsync(PropertyType keyType, PropertyType valType, MapType mapType, String mapName)
Creates a session-bound map
|
<ID extends Comparable<ID>> |
createPath(PgxVertex<ID> src, PgxVertex<ID> dst, EdgeProperty<Double> cost, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge)
Blocking version of
#createPathAsync() . |
<ID extends Comparable<ID>> |
createPathAsync(PgxVertex<ID> src, PgxVertex<ID> dst, EdgeProperty<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). |
<T> Scalar<T> |
createScalar(PropertyType type)
Blocking version of
#createScalarAsync() . |
<T> Scalar<T> |
createScalar(PropertyType type, String newScalarName)
Blocking version of
#createScalarAsync() . |
<T> PgxFuture<Scalar<T>> |
createScalarAsync(PropertyType type)
Creates a new Scalar.
|
<T> PgxFuture<Scalar<T>> |
createScalarAsync(PropertyType type, String newScalarName)
Create a session-bound scalar.
|
<ID extends Comparable<ID>,V extends Comparable<V>> |
createVertexProperty(PropertyType type)
Blocking version of
#createVertexPropertyAsync() . |
<ID extends Comparable<ID>,V extends Comparable<V>> |
createVertexProperty(PropertyType type, String name)
Blocking version of
#createVertexPropertyAsync() . |
<ID extends Comparable<ID>,V extends Comparable<V>> |
createVertexPropertyAsync(PropertyType type)
Creates a session-bound vertex property
|
<ID extends Comparable<ID>,V extends Comparable<V>> |
createVertexPropertyAsync(PropertyType type, String name)
Creates a session-bound vertex property
|
<E extends Comparable<E>> |
createVertexSequence()
Blocking version of
createVertexSequenceAsync() . |
<E extends Comparable<E>> |
createVertexSequence(String name)
Blocking version of
createVertexSequenceAsync() . |
<E extends Comparable<E>> |
createVertexSequenceAsync()
Creates a new Vertex Sequence.
|
<E extends Comparable<E>> |
createVertexSequenceAsync(String name)
Creates a new Vertex Sequence.
|
<E extends Comparable<E>> |
createVertexSet()
Blocking version of
createVertexSetAsync() . |
<E extends Comparable<E>> |
createVertexSet(String name)
Blocking version of
createVertexSetAsync() . |
<E extends Comparable<E>> |
createVertexSetAsync()
Creates a new Vertex Set.
|
<E extends Comparable<E>> |
createVertexSetAsync(String name)
Creates a new Vertex Set.
|
PgxGraph |
filter(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, GraphFilter graphFilter, String newGraphName)
Blocking version of
#filterAsync() . |
PgxGraph |
filter(GraphFilter graphFilter)
Blocking version of
#filterAsync() . |
PgxGraph |
filter(GraphFilter graphFilter, String newGraphName)
Blocking version of
#filterAsync() . |
PgxFuture<PgxGraph> |
filterAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, GraphFilter graphFilter, String newGraphName)
Create a subgraph of a graph.
|
PgxFuture<PgxGraph> |
filterAsync(GraphFilter graphFilter)
Create a subgraph of a graph.
|
PgxFuture<PgxGraph> |
filterAsync(GraphFilter graphFilter, String newGraphName)
Create a subgraph of a 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.
|
String |
getDataSourceVersion()
Gets the format-specific version identifier provided by data-source (timestamp for files, snapshot ID for databases).
|
PgxEdge |
getEdge(long id)
Gets a
PgxEdge of this graph by ID. |
Set<EdgeProperty<?>> |
getEdgeProperties()
Blocking version of
getEdgePropertiesAsync() . |
PgxFuture<Set<EdgeProperty<?>>> |
getEdgePropertiesAsync()
Get the set of edge properties belonging to this graph.
|
<V extends Comparable<V>> |
getEdgeProperty(String name)
Blocking version of
#getEdgePropertyAsync() . |
<V extends Comparable<V>> |
getEdgePropertyAsync(String name)
get an edge property of this graph
|
EdgeSet |
getEdges(EdgeFilter filter)
Blocking version of
#getEdges() . |
<E extends Comparable<E>> |
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).
|
String |
getName() |
long |
getNumEdges()
Gets the number of edges
|
long |
getNumVertices()
Gets the number of vertices
|
ServerInstance |
getPgxInstance() |
PgxSession |
getSession() |
<ID extends Comparable<ID>> |
getVertex(ID id)
Gets a
PgxVertex of this graph by ID. |
IdType |
getVertexIdType()
Gets the vertex ID type of this graph.
|
Set<VertexProperty<?,?>> |
getVertexProperties()
Blocking version of
getVertexPropertiesAsync() . |
PgxFuture<Set<VertexProperty<?,?>>> |
getVertexPropertiesAsync()
Get the set of vertex properties belonging to this graph.
|
<ID extends Comparable<ID>,V extends Comparable<V>> |
getVertexProperty(String name)
Blocking version of
#getVertexPropertyAsync() . |
<ID extends Comparable<ID>,V extends Comparable<V>> |
getVertexPropertyAsync(String name)
Gets a vertex property of this graph
|
<E extends Comparable<E>> |
getVertices(VertexFilter filter)
Blocking version of
#getVerticesAsync() . |
<E extends Comparable<E>> |
getVerticesAsync(VertexFilter filter)
Creates a new Vertex Set containing vertices according to the given filter expression.
|
boolean |
isFresh()
Blocking version of
isFreshAsync() . |
PgxFuture<Boolean> |
isFreshAsync()
Check whether an in-memory representation of a graph is fresh.
|
boolean |
isTransient() |
<ID extends Comparable<ID>> |
pickRandomVertex()
Blocking version of
pickRandomVertexAsync() . |
<ID extends Comparable<ID>> |
pickRandomVertexAsync()
Picks a random vertex in the graph.
|
PgxGraph |
simplify(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
Blocking version of
#simplifyAsync() . |
PgxGraph |
simplify(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
Blocking version of
#simplifyAsync() . |
PgxFuture<PgxGraph> |
simplifyAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
Create a simplified version of a graph.
|
PgxFuture<PgxGraph> |
simplifyAsync(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, 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. |
PgxGraph |
sortByDegree()
Blocking version of
sortByDegreeAsync() . |
PgxGraph |
sortByDegree(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, PgxGraph.Direction direction, PgxGraph.Degree degree, PgxGraph.Mode mode, String newGraphName)
Blocking version of
sortByDegreeAsync() . |
PgxGraph |
sortByDegree(PgxGraph.Direction direction, PgxGraph.Degree degree, PgxGraph.Mode mode, String newGraphName)
Blocking version of
sortByDegreeAsync() . |
PgxGraph |
sortByDegree(String newGraphName)
Blocking version of
sortByDegreeAsync() . |
PgxFuture<PgxGraph> |
sortByDegreeAsync()
Create a sorted version of a graph and all its properties.
|
PgxFuture<PgxGraph> |
sortByDegreeAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, PgxGraph.Direction direction, PgxGraph.Degree degree, PgxGraph.Mode mode, String newGraphName)
Create a sorted version of a graph and all its properties.
|
PgxFuture<PgxGraph> |
sortByDegreeAsync(PgxGraph.Direction direction, PgxGraph.Degree degree, PgxGraph.Mode mode, String newGraphName)
Create a sorted version of a graph and all its properties.
|
PgxFuture<PgxGraph> |
sortByDegreeAsync(String newGraphName)
Create a sorted version of a graph and all its properties.
|
PgxGraph |
sparsify(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, double e, String newGraphName)
Blocking version of
#sparsifyAsync() . |
PgxGraph |
sparsify(double e)
Blocking version of
#sparsifyAsync() . |
PgxGraph |
sparsify(double e, String newGraphName)
Blocking version of
#sparsifyAsync() . |
PgxFuture<PgxGraph> |
sparsifyAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, double e, 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 sparsify(double, String) Passing newGraphName as null |
PgxFuture<PgxGraph> |
sparsifyAsync(double e, String newGraphName)
Sparsifies the given graph and returns a new graph with less edges.
Convenience method around sparsify(Collection, Collection, double, String) Passing vertexProps as VertexProperty.ALL edgeProps as EdgeProperty.ALL |
FileGraphConfig |
store(Format targetFormat, String targetPath)
Blocking version of
storeAsync(Format, String) . |
FileGraphConfig |
store(Format targetFormat, String targetPath, boolean overwrite)
Blocking version of
storeAsync(Format, String, boolean) . |
FileGraphConfig |
store(Format targetFormat, String targetPath, Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(Format, String, Collection, Collection, boolean) . |
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, String targetPath) |
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, String targetPath, boolean overwrite) |
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, String targetPath, Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, boolean overwrite) |
String |
toString() |
PgxGraph |
undirect()
Blocking version of
undirectAsync() . |
PgxGraph |
undirect(Collection<VertexProperty<?,?>> vertexProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
Blocking version of
undirectAsync() . |
PgxGraph |
undirect(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
Blocking version of
undirectAsync() . |
PgxGraph |
undirect(String newGraphName)
Blocking version of
undirectAsync() . |
PgxFuture<PgxGraph> |
undirectAsync()
Convenience method around
undirectAsync(String) Passing String(newGraphName) as null |
PgxFuture<PgxGraph> |
undirectAsync(Collection<VertexProperty<?,?>> vertexProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
Create an undirected version of a graph.
|
PgxFuture<PgxGraph> |
undirectAsync(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
Convenience method for
undirectAsync(Collection, MultiEdges, SelfEdges, TrivialVertices, Mode, String) Passing Collection(vertexProps) as VertexProperty.ALL |
PgxFuture<PgxGraph> |
undirectAsync(String newGraphName)
Convenience method around
undirectAsync(MultiEdges, SelfEdges, TrivialVertices, Mode, String) Passing MultiEdges as MultiEdges.KEEP_MULTI_EDGES SelfEdges as SelfEdges.KEEP_SELF_EDGES Trivial Vertices as TrivialVertices.KEEP_TRIVIALVERTICES Mode as Mode.CREATE_COPY |
equals, hashCode
close, destroy, destroyAsync
@Generated(value="src/python/synchronize.py") public BipartiteGraph bipartiteSubGraphFromLeftSet(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, String newGraphName) throws ExecutionException, InterruptedException
#bipartiteSubGraphFromLeftSetAsync()
. Calls #bipartiteSubGraphFromLeftSetAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public BipartiteGraph bipartiteSubGraphFromLeftSet(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, String newGraphName, String isLeftPropName) throws ExecutionException, InterruptedException
#bipartiteSubGraphFromLeftSetAsync()
. Calls #bipartiteSubGraphFromLeftSetAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public BipartiteGraph bipartiteSubGraphFromLeftSet(VertexSet<?> vertexSet) throws ExecutionException, InterruptedException
#bipartiteSubGraphFromLeftSetAsync()
. Calls #bipartiteSubGraphFromLeftSetAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public BipartiteGraph bipartiteSubGraphFromLeftSet(VertexSet<?> vertexSet, String newGraphName) throws ExecutionException, InterruptedException
#bipartiteSubGraphFromLeftSetAsync()
. Calls #bipartiteSubGraphFromLeftSetAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<BipartiteGraph> bipartiteSubGraphFromLeftSetAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, 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.isLeftPropName
- after the method finishes, the name that will be associated with a boolean property that will contain the information whether a node is on the left side of the bipartite subgraph. The name must not be a name of an existing node property for this graph. If the argument is null, a new unique name will be created.public PgxFuture<BipartiteGraph> bipartiteSubGraphFromLeftSetAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, VertexSet<?> vertexSet, String newGraphName, String isLeftPropName)
public PgxFuture<BipartiteGraph> bipartiteSubGraphFromLeftSetAsync(VertexSet<?> vertexSet)
#bipartiteSubGraphFromLeftSet(Collection, Collection, VertexSet)
VertexProperty.ALL
EdgeProperty.ALL
vertexSet
- vertex set representing the left sidepublic PgxFuture<BipartiteGraph> bipartiteSubGraphFromLeftSetAsync(VertexSet<?> vertexSet, String newGraphName)
bipartiteSubGraphFromLeftSetAsync(Collection, Collection, VertexSet, String, String)
passing newGraphName and isLeftPropName as null
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 side@Generated(value="src/python/synchronize.py") public PgxGraph clone()
cloneAsync()
. Calls cloneAsync()
and waits for the returned PgxFuture
to complete.clone
in class Object
InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph clone(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, String newGraphName) throws ExecutionException, InterruptedException
cloneAsync()
. Calls cloneAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph clone(String newGraphName) throws ExecutionException, InterruptedException
cloneAsync()
. Calls cloneAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> cloneAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, 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(String newGraphName)
cloneAsync(Collection, Collection, String)
VertexProperty.ALL
EdgeProperty.ALL
newGraphName
- name of the new graph. If null, a name will be generated.@Generated(value="src/python/synchronize.py") public <ID extends Comparable<ID>> AllPaths<ID> createAllPaths(PgxVertex<ID> src, EdgeProperty<Double> cost, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge) throws ExecutionException, InterruptedException
#createAllPathsAsync()
. Calls #createAllPathsAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID extends Comparable<ID>> PgxFuture<AllPaths<ID>> createAllPathsAsync(PgxVertex<ID> src, EdgeProperty<Double> cost, 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.@Generated(value="src/python/synchronize.py") public <ID extends Comparable<ID>> Partition<ID> createComponents(VertexProperty<ID,Integer> components, int numComponents) throws ExecutionException, InterruptedException
#createComponentsAsync()
. Calls #createComponentsAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID extends Comparable<ID>> PgxFuture<Partition<ID>> createComponentsAsync(VertexProperty<ID,Integer> components, int 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.@Generated(value="src/python/synchronize.py") public <V extends Comparable<V>> EdgeProperty<V> createEdgeProperty(PropertyType type) throws ExecutionException, InterruptedException
#createEdgePropertyAsync()
. Calls #createEdgePropertyAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public <V extends Comparable<V>> EdgeProperty<V> createEdgeProperty(PropertyType type, String name) throws ExecutionException, InterruptedException
#createEdgePropertyAsync()
. Calls #createEdgePropertyAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <V extends Comparable<V>> PgxFuture<EdgeProperty<V>> createEdgePropertyAsync(PropertyType type)
type
- type of property to createpublic <V extends Comparable<V>> PgxFuture<EdgeProperty<V>> createEdgePropertyAsync(PropertyType type, String name)
type
- type of property to createname
- of property to be created@Generated(value="src/python/synchronize.py") public EdgeSequence createEdgeSequence() throws ExecutionException, InterruptedException
createEdgeSequenceAsync()
. Calls createEdgeSequenceAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public EdgeSequence createEdgeSequence(String name) throws ExecutionException, InterruptedException
createEdgeSequenceAsync()
. Calls createEdgeSequenceAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<EdgeSequence> createEdgeSequenceAsync()
public PgxFuture<EdgeSequence> createEdgeSequenceAsync(String name)
name
- name of the Edge Sequence to be created@Generated(value="src/python/synchronize.py") public EdgeSet createEdgeSet() throws ExecutionException, InterruptedException
createEdgeSetAsync()
. Calls createEdgeSetAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public EdgeSet createEdgeSet(String name) throws ExecutionException, InterruptedException
createEdgeSetAsync()
. Calls createEdgeSetAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<EdgeSet> createEdgeSetAsync()
public PgxFuture<EdgeSet> createEdgeSetAsync(String name)
name
- name of the Edge Set to be created@Generated(value="src/python/synchronize.py") public <K extends Comparable<K>,V extends Comparable<V>> PgxMap<K,V> createMap(PropertyType keyType, PropertyType valType) throws ExecutionException, InterruptedException
#createMapAsync()
. Calls #createMapAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public <K extends Comparable<K>,V extends Comparable<V>> PgxMap<K,V> createMap(PropertyType keyType, PropertyType valType, MapType mapType) throws ExecutionException, InterruptedException
#createMapAsync()
. Calls #createMapAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public <K extends Comparable<K>,V extends Comparable<V>> PgxMap<K,V> createMap(PropertyType keyType, PropertyType valType, MapType mapType, String mapName) throws ExecutionException, InterruptedException
#createMapAsync()
. Calls #createMapAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <K extends Comparable<K>,V extends Comparable<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 extends Comparable<K>,V extends Comparable<V>> PgxFuture<PgxMap<K,V>> createMapAsync(PropertyType keyType, PropertyType valType, MapType mapType)
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 mapmapType
- Type of the map that is going to be createdpublic <K extends Comparable<K>,V extends Comparable<V>> PgxFuture<PgxMap<K,V>> createMapAsync(PropertyType keyType, PropertyType valType, MapType mapType, 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 mapmapType
- Type of the map that is going to be createdmapName
- how the map should be named@Generated(value="src/python/synchronize.py") public <ID extends Comparable<ID>> PgxPath<ID> createPath(PgxVertex<ID> src, PgxVertex<ID> dst, EdgeProperty<Double> cost, VertexProperty<ID,PgxVertex<ID>> parent, VertexProperty<ID,PgxEdge> parentEdge) throws ExecutionException, InterruptedException
#createPathAsync()
. Calls #createPathAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID extends Comparable<ID>> PgxFuture<PgxPath<ID>> createPathAsync(PgxVertex<ID> src, PgxVertex<ID> dst, EdgeProperty<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.@Generated(value="src/python/synchronize.py") public <T> Scalar<T> createScalar(PropertyType type) throws ExecutionException, InterruptedException
#createScalarAsync()
. Calls #createScalarAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public <T> Scalar<T> createScalar(PropertyType type, String newScalarName) throws ExecutionException, InterruptedException
#createScalarAsync()
. Calls #createScalarAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.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, String newScalarName)
newScalarName
- name of the scalar to be createdtype
- the type of scalar@Generated(value="src/python/synchronize.py") public <ID extends Comparable<ID>,V extends Comparable<V>> VertexProperty<ID,V> createVertexProperty(PropertyType type) throws ExecutionException, InterruptedException
#createVertexPropertyAsync()
. Calls #createVertexPropertyAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public <ID extends Comparable<ID>,V extends Comparable<V>> VertexProperty<ID,V> createVertexProperty(PropertyType type, String name) throws ExecutionException, InterruptedException
#createVertexPropertyAsync()
. Calls #createVertexPropertyAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID extends Comparable<ID>,V extends Comparable<V>> PgxFuture<VertexProperty<ID,V>> createVertexPropertyAsync(PropertyType type)
type
- type of the property to createpublic <ID extends Comparable<ID>,V extends Comparable<V>> PgxFuture<VertexProperty<ID,V>> createVertexPropertyAsync(PropertyType type, String name)
type
- type of property to createname
- of property to be created@Generated(value="src/python/synchronize.py") public <E extends Comparable<E>> VertexSequence<E> createVertexSequence() throws ExecutionException, InterruptedException
createVertexSequenceAsync()
. Calls createVertexSequenceAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public <E extends Comparable<E>> VertexSequence<E> createVertexSequence(String name) throws ExecutionException, InterruptedException
createVertexSequenceAsync()
. Calls createVertexSequenceAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E extends Comparable<E>> PgxFuture<VertexSequence<E>> createVertexSequenceAsync()
public <E extends Comparable<E>> PgxFuture<VertexSequence<E>> createVertexSequenceAsync(String name)
name
- the name of the collection to be created@Generated(value="src/python/synchronize.py") public <E extends Comparable<E>> VertexSet<E> createVertexSet() throws ExecutionException, InterruptedException
createVertexSetAsync()
. Calls createVertexSetAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public <E extends Comparable<E>> VertexSet<E> createVertexSet(String name) throws ExecutionException, InterruptedException
createVertexSetAsync()
. Calls createVertexSetAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E extends Comparable<E>> PgxFuture<VertexSet<E>> createVertexSetAsync()
public <E extends Comparable<E>> PgxFuture<VertexSet<E>> createVertexSetAsync(String name)
name
- name of the vertex set to be created@Generated(value="src/python/synchronize.py") public PgxGraph filter(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, GraphFilter graphFilter, String newGraphName) throws ExecutionException, InterruptedException
#filterAsync()
. Calls #filterAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph filter(GraphFilter graphFilter) throws ExecutionException, InterruptedException
#filterAsync()
. Calls #filterAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph filter(GraphFilter graphFilter, String newGraphName) throws ExecutionException, InterruptedException
#filterAsync()
. Calls #filterAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> filterAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, GraphFilter graphFilter, 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)
filterAsync(GraphFilter, String)
null
graphFilter
- GraphFilter object representing a filter expression that is applied to create the subgraphpublic PgxFuture<PgxGraph> filterAsync(GraphFilter graphFilter, String newGraphName)
filterAsync(Collection, Collection, GraphFilter, String)
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 String getDataSourceVersion()
null
if graph was not created from a datasource ( isTransient()
is true
).public PgxEdge getEdge(long id)
PgxEdge
of this graph by ID. Note that this method does *not* check whether the given ID exists.id
- the ID of the vertexPgxEdge
object@Generated(value="src/python/synchronize.py") public Set<EdgeProperty<?>> getEdgeProperties() throws ExecutionException, InterruptedException
getEdgePropertiesAsync()
. Calls getEdgePropertiesAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<Set<EdgeProperty<?>>> getEdgePropertiesAsync()
@Generated(value="src/python/synchronize.py") public <V extends Comparable<V>> EdgeProperty<V> getEdgeProperty(String name) throws ExecutionException, InterruptedException
#getEdgePropertyAsync()
. Calls #getEdgePropertyAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <V extends Comparable<V>> PgxFuture<EdgeProperty<V>> getEdgePropertyAsync(String name)
name
- the name of the edge propertynull
if no such property existsNullPointerException
- if the passed name is null@Generated(value="src/python/synchronize.py") public EdgeSet getEdges(EdgeFilter filter) throws InterruptedException, ExecutionException
InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E extends Comparable<E>> PgxFuture<EdgeSet> getEdgesAsync(EdgeFilter filter)
filter
- the edge filter expression used to create the Edge Setpublic long getMemoryMb()
public String getName()
getName
in class PgxManagedObject
public long getNumEdges()
public long getNumVertices()
public ServerInstance getPgxInstance()
public PgxSession getSession()
public <ID extends Comparable<ID>> PgxVertex<ID> getVertex(ID id)
PgxVertex
of this graph by ID. Note that this method does *not* check whether the given ID exists.id
- the ID of the vertexPgxVertex
objectIllegalArgumentException
- if given ID is null
or not of type IdType
public IdType getVertexIdType()
@Generated(value="src/python/synchronize.py") public Set<VertexProperty<?,?>> getVertexProperties() throws ExecutionException, InterruptedException
getVertexPropertiesAsync()
. Calls getVertexPropertiesAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<Set<VertexProperty<?,?>>> getVertexPropertiesAsync()
@Generated(value="src/python/synchronize.py") public <ID extends Comparable<ID>,V extends Comparable<V>> VertexProperty<ID,V> getVertexProperty(String name) throws ExecutionException, InterruptedException
#getVertexPropertyAsync()
. Calls #getVertexPropertyAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID extends Comparable<ID>,V extends Comparable<V>> PgxFuture<VertexProperty<ID,V>> getVertexPropertyAsync(String name)
name
- the name of the vertex propertynull
if no such property existsNullPointerException
- if the passed name is null@Generated(value="src/python/synchronize.py") public <E extends Comparable<E>> VertexSet<E> getVertices(VertexFilter filter) throws InterruptedException, ExecutionException
#getVerticesAsync()
. Calls #getVerticesAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <E extends Comparable<E>> PgxFuture<VertexSet<E>> getVerticesAsync(VertexFilter filter)
filter
- the vertex filter expression used to create the Vertex Set@Generated(value="src/python/synchronize.py") public boolean isFresh() throws ExecutionException, InterruptedException
isFreshAsync()
. Calls isFreshAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<Boolean> isFreshAsync()
public boolean isTransient()
true
if this graph is transient (session-bound, private), false
otherwise.@Generated(value="src/python/synchronize.py") public <ID extends Comparable<ID>> PgxVertex<ID> pickRandomVertex() throws ExecutionException, InterruptedException
pickRandomVertexAsync()
. Calls pickRandomVertexAsync()
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public <ID extends Comparable<ID>> PgxFuture<PgxVertex<ID>> pickRandomVertexAsync()
@Generated(value="src/python/synchronize.py") public PgxGraph simplify(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName) throws ExecutionException, InterruptedException
#simplifyAsync()
. Calls #simplifyAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph simplify(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName) throws ExecutionException, InterruptedException
#simplifyAsync()
. Calls #simplifyAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> simplifyAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, 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
cane 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(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
simplifyAsync(Collection, Collection, MultiEdges, SelfEdges, TrivialVertices, Mode, String)
VertexProperty.ALL
EdgeProperty.ALL
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
cane 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.@Generated(value="src/python/synchronize.py") public PgxGraph sortByDegree() throws ExecutionException, InterruptedException
sortByDegreeAsync()
. Calls sortByDegreeAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph sortByDegree(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, PgxGraph.Direction direction, PgxGraph.Degree degree, PgxGraph.Mode mode, String newGraphName) throws ExecutionException, InterruptedException
sortByDegreeAsync()
. Calls sortByDegreeAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph sortByDegree(PgxGraph.Direction direction, PgxGraph.Degree degree, PgxGraph.Mode mode, String newGraphName) throws ExecutionException, InterruptedException
sortByDegreeAsync()
. Calls sortByDegreeAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph sortByDegree(String newGraphName) throws ExecutionException, InterruptedException
sortByDegreeAsync()
. Calls sortByDegreeAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> sortByDegreeAsync()
sortByDegree(String)
null
public PgxFuture<PgxGraph> sortByDegreeAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, PgxGraph.Direction direction, PgxGraph.Degree degree, PgxGraph.Mode mode, 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.direction
- order direction. Constants PgxGraph.Direction.ASCENDING
or PgxGraph.Direction.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.Direction direction, PgxGraph.Degree degree, PgxGraph.Mode mode, String newGraphName)
sortByDegreeAsync(Collection, Collection, Direction, Degree, Mode, String)
VertexProperty.ALL
EdgeProperty.ALL
direction
- order direction. Constants PgxGraph.Direction.ASCENDING
or PgxGraph.Direction.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(String newGraphName)
sortByDegree(Direction, Degree, Mode, String)
Direction.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.@Generated(value="src/python/synchronize.py") public PgxGraph sparsify(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, double e, String newGraphName) throws ExecutionException, InterruptedException
#sparsifyAsync()
. Calls #sparsifyAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph sparsify(double e) throws ExecutionException, InterruptedException
#sparsifyAsync()
. Calls #sparsifyAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph sparsify(double e, String newGraphName) throws ExecutionException, InterruptedException
#sparsifyAsync()
. Calls #sparsifyAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> sparsifyAsync(Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, double e, 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)
sparsify(double, String)
null
e
- the sparsification coefficientnewGraphName
- name of the new graph. If null, a name will be generated.public PgxFuture<PgxGraph> sparsifyAsync(double e, String newGraphName)
sparsify(Collection, Collection, double, String)
VertexProperty.ALL
EdgeProperty.ALL
e
- the sparsification coefficient. Must be between 0.0 and 1.1.newGraphName
- name of the new graph. If null, a name will be generated.@Generated(value="src/python/synchronize.py") public FileGraphConfig store(Format targetFormat, String targetPath) throws ExecutionException, InterruptedException
storeAsync(Format, String)
. Calls storeAsync(Format, String)
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public FileGraphConfig store(Format targetFormat, String targetPath, boolean overwrite) throws ExecutionException, InterruptedException
storeAsync(Format, String, boolean)
. Calls storeAsync(Format, String, boolean)
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public FileGraphConfig store(Format targetFormat, String targetPath, Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws ExecutionException, InterruptedException
storeAsync(Format, String, Collection, Collection, boolean)
. Calls storeAsync(Format, String, Collection, Collection, boolean)
and waits for returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, String targetPath)
public PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, String targetPath, boolean overwrite)
public PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, String targetPath, Collection<VertexProperty<?,?>> vertexProps, Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
public String toString()
toString
in class PgxManagedObject
@Generated(value="src/python/synchronize.py") public PgxGraph undirect() throws ExecutionException, InterruptedException
undirectAsync()
. Calls undirectAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph undirect(Collection<VertexProperty<?,?>> vertexProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName) throws ExecutionException, InterruptedException
undirectAsync()
. Calls undirectAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph undirect(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName) throws ExecutionException, InterruptedException
undirectAsync()
. Calls undirectAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.@Generated(value="src/python/synchronize.py") public PgxGraph undirect(String newGraphName) throws ExecutionException, InterruptedException
undirectAsync()
. Calls undirectAsync()
and waits for the returned PgxFuture
to complete.InterruptedException
- if the caller thread gets interrupted while waiting for completion.ExecutionException
- if any exception occurred during asynchronous execution. The actual exception will be nested.public PgxFuture<PgxGraph> undirectAsync()
undirectAsync(String)
Passing String(newGraphName) as nullpublic PgxFuture<PgxGraph> undirectAsync(Collection<VertexProperty<?,?>> vertexProps, PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
vertexProps
- vertex properties belonging to graph. Constants VertexProperty.ALL
or VertexProperty.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
cane 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> undirectAsync(PgxGraph.MultiEdges multiEdges, PgxGraph.SelfEdges selfEdges, PgxGraph.TrivialVertices trivialVertices, PgxGraph.Mode mode, String newGraphName)
undirectAsync(Collection, MultiEdges, SelfEdges, TrivialVertices, Mode, String)
VertexProperty.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
cane 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> undirectAsync(String newGraphName)
undirectAsync(MultiEdges, SelfEdges, TrivialVertices, Mode, String)
MultiEdges.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 © 2015. All rights reserved.