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 |
oracle.pgx.api.PgxGraph.Retention
Deprecated.
|
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 |
---|---|
void |
addRedactionRule(oracle.pgx.config.PgxRedactionRuleConfig ruleConfig, AuthorizationType type, java.lang.String... names)
Blocking version of
addRedactionRule(PgxRedactionRuleConfig, AuthorizationType, String...) Calls addRedactionRuleAsync(PgxRedactionRuleConfig, AuthorizationType, String...) )} and waits for the returned PgxFuture to complete. |
PgxFuture<java.lang.Void> |
addRedactionRuleAsync(oracle.pgx.config.PgxRedactionRuleConfig ruleConfig, AuthorizationType type, java.lang.String... names)
Add a redaction rule configuration for an AuthorizationType names.
|
GraphAlterationBuilder |
alterGraph()
Create a graph alteration builder to define the graph schema alterations to perform on the graph
|
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) . |
PgxGraph |
cloneAndExecutePgql(java.lang.String pgqlString)
(BETA) Blocking version of
cloneAndExecutePgqlAsync(String) . |
PgxGraph |
cloneAndExecutePgql(java.lang.String pgqlString, java.lang.String graphName)
(BETA) Blocking version of
cloneAndExecutePgqlAsync(String, String) . |
PgxFuture<PgxGraph> |
cloneAndExecutePgqlAsync(java.lang.String pgqlString)
|
PgxFuture<PgxGraph> |
cloneAndExecutePgqlAsync(java.lang.String pgqlString, java.lang.String newGraphName)
(BETA) Submits a pattern matching query (from a PgxGraph) on a clone of the graph.
|
PgxFuture<PgxGraph> |
cloneAsync()
|
PgxFuture<PgxGraph> |
cloneAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName)
Creates a deep 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> 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)
|
<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 using
IdGenerationStrategy.AUTO_GENERATED for edge ID generation strategy Note: This is currently not supported for undirected graphs. |
<ID extends java.lang.Comparable<ID>> |
createChangeSet(IdGenerationStrategy vertexIdGenerationStrategy, IdGenerationStrategy edgeIdGenerationStrategy)
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). |
<ID> PgxFuture<PgxPath<ID>> |
createPathAsync(VertexSequence<ID> nodeSequence, EdgeSequence edgeSequence)
Creates a
PgxPath object from a sequence of vertices and edges. |
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 extends Synchronizer> |
createSynchronizer(java.lang.Class<T> type)
Creates a synchronizer object which can be used to keep this graph in sync with changes happening in its original data source.
|
<T extends Synchronizer> |
createSynchronizer(java.lang.Class<T> type, java.sql.Connection conn)
Creates a synchronizer object which can be used to keep this graph in sync with changes happening in its original data source.
|
<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
|
void |
destroy()
Blocking version of
destroyAsync() . |
PgxFuture<java.lang.Void> |
destroyAsync()
Destroy a graph with all its properties.
|
void |
destroyEdgePropertyIfExists(java.lang.String name)
Blocking version of
destroyEdgePropertyIfExistsAsync(String) . |
PgxFuture<java.lang.Void> |
destroyEdgePropertyIfExistsAsync(java.lang.String name)
Destroys an edge property if it exists.
|
void |
destroyVertexPropertyIfExists(java.lang.String name)
Blocking version of
destroyVertexPropertyIfExistsAsync(String) . |
PgxFuture<java.lang.Void> |
destroyVertexPropertyIfExistsAsync(java.lang.String name)
Destroys a vertex property if it exists.
|
boolean |
equals(java.lang.Object obj) |
PgqlResultSet |
executePgql(java.lang.String pgqlString)
(BETA) Blocking version of
executePgqlAsync(String) . |
PgxFuture<PgqlResultSet> |
executePgqlAsync(java.lang.String pgqlString)
(BETA) Submits a PGQL (both select and modify) query.
|
Operation |
explainPgql(java.lang.String pgqlString)
Blocking version of
explainPgql(String) . |
PgxFuture<Operation> |
explainPgqlAsync(java.lang.String pgqlString)
Explain the execution plan of a pattern matching query.
|
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.
|
java.util.Map<java.lang.String,PgxCollection<? extends PgxEntity<?>,?>> |
getCollections()
Blocking version of
getCollectionsAsync() . |
PgxFuture<java.util.Map<java.lang.String,PgxCollection<? extends PgxEntity<?>,?>>> |
getCollectionsAsync()
Retrieves all currently allocated collections associated with the 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. |
IdStrategy |
getEdgeIdStrategy()
Gets the ID strategy used for the edges of this graph.
|
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(Namespace namespace, java.lang.String name)
Blocking version of
getEdgePropertyAsync(Namespace, String) . |
<V> EdgeProperty<V> |
getEdgeProperty(java.lang.String name)
Blocking version of
getEdgePropertyAsync(String) . |
<V> PgxFuture<EdgeProperty<V>> |
getEdgePropertyAsync(Namespace namespace, java.lang.String name)
Gets an edge property of this graph in the given namespace.
|
<V> PgxFuture<EdgeProperty<V>> |
getEdgePropertyAsync(java.lang.String name)
Gets an edge property of this graph The property will be first looked up in the session private namespace, if it is not found there it will be looked up in the public namespace.
|
EdgeSet |
getEdges()
Blocking version of
getEdges() . |
EdgeSet |
getEdges(EdgeFilter filter)
Blocking version of
getEdges(EdgeFilter) . |
EdgeSet |
getEdges(EdgeFilter filter, java.lang.String name)
Blocking version of
getEdges(EdgeFilter, String) . |
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.
|
PgxFuture<EdgeSet> |
getEdgesAsync(EdgeFilter filter, java.lang.String name)
Creates a new edge set containing edges according to the given filter expression.
|
oracle.pgx.common.PgxId |
getId()
Returns an internal identifier for this graph snapshot.
|
long |
getMemoryMb()
Gets the estimated number of memory this graph (including its properties) consumes in memory (in megabytes).
|
GraphMetaData |
getMetaData()
Provides the metadata associated to this graph snapshot which includes information about the structure of the graph, versioning information, etc.
|
java.lang.String |
getName()
Gets the name.
|
long |
getNumEdges()
Gets the number of edges
|
long |
getNumVertices()
Gets the number of vertices
|
<V> EdgeProperty<V> |
getOrCreateEdgeProperty(PropertyType type, java.lang.String name)
Blocking version of
getOrCreateEdgePropertyAsync(PropertyType, String) . |
<V> PgxFuture<EdgeProperty<V>> |
getOrCreateEdgePropertyAsync(PropertyType type, java.lang.String name)
Gets or creates an edge property
|
<V> EdgeProperty<PgxVect<V>> |
getOrCreateEdgeVectorProperty(PropertyType type, int dimension, java.lang.String name)
Blocking version of
getOrCreateEdgeVectorPropertyAsync(PropertyType, int, String) . |
<V> PgxFuture<EdgeProperty<PgxVect<V>>> |
getOrCreateEdgeVectorPropertyAsync(PropertyType type, int dimension, java.lang.String name)
Gets or creates an edge vector property
|
<V> PgxFuture<EdgeProperty<PgxVect<V>>> |
getOrCreateEdgeVertexPropertyAsync(PropertyType type, int dimension, java.lang.String name)
Gets or creates an edge vector property
|
<ID,V> VertexProperty<ID,V> |
getOrCreateVertexProperty(PropertyType type, java.lang.String name)
Blocking version of
getOrCreateVertexPropertyAsync(PropertyType, String) . |
<ID,V> PgxFuture<VertexProperty<ID,V>> |
getOrCreateVertexPropertyAsync(PropertyType type, java.lang.String name)
Gets or creates a vertex property
|
<ID,V> VertexProperty<ID,PgxVect<V>> |
getOrCreateVertexVectorProperty(PropertyType type, int dimension, java.lang.String name)
Blocking version of
getOrCreateVertexVectorPropertyAsync(PropertyType, int, String) . |
<ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> |
getOrCreateVertexVectorPropertyAsync(PropertyType type, int dimension, java.lang.String name)
Gets or creates a vertex vector property
|
ServerInstance |
getPgxInstance()
Gets the server instance.
|
PgxEdge |
getRandomEdge()
Blocking version of
getRandomEdgeAsync() . |
PgxFuture<PgxEdge> |
getRandomEdgeAsync()
Picks a random edge in the graph.
|
<ID> PgxVertex<ID> |
getRandomVertex()
Blocking version of
getRandomVertexAsync() . |
<ID> PgxFuture<PgxVertex<ID>> |
getRandomVertexAsync()
Picks a random vertex in the graph.
|
java.util.List<oracle.pgx.config.PgxRedactionRuleConfig> |
getRedactionRules(AuthorizationType type, java.lang.String name)
Blocking version of
getRedactionRules(AuthorizationType, String) Calls getRedactionRulesAsync(AuthorizationType, String) )} and waits for the returned PgxFuture to complete. |
PgxFuture<java.util.List<oracle.pgx.config.PgxRedactionRuleConfig>> |
getRedactionRulesAsync(AuthorizationType type, java.lang.String name)
Gets redaction rules for an AuthorizationType name.
|
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. |
IdStrategy |
getVertexIdStrategy()
Gets the ID strategy used for the vertices of this graph.
|
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(Namespace namespace, java.lang.String name)
Blocking version of
getVertexPropertyAsync(Namespace, String) . |
<ID,V> VertexProperty<ID,V> |
getVertexProperty(java.lang.String name)
Blocking version of
getVertexPropertyAsync(String) . |
<ID,V> PgxFuture<VertexProperty<ID,V>> |
getVertexPropertyAsync(Namespace namespace, java.lang.String name)
Gets a vertex property of this graph in the given namespace.
|
<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.
|
void |
grantPermission(oracle.pgx.common.auth.PgxRole role, oracle.pgx.common.auth.PgxResourcePermission permission)
Blocking version of
grantPermissionAsync(PgxRole, PgxResourcePermission) . |
void |
grantPermission(oracle.pgx.common.auth.PgxUser user, oracle.pgx.common.auth.PgxResourcePermission permission)
Blocking version of
grantPermissionAsync(PgxUser, PgxResourcePermission) . |
PgxFuture<java.lang.Void> |
grantPermissionAsync(oracle.pgx.common.auth.PgxRole role, oracle.pgx.common.auth.PgxResourcePermission permission)
Grants a permission on this graph to the given role.
|
PgxFuture<java.lang.Void> |
grantPermissionAsync(oracle.pgx.common.auth.PgxUser user, oracle.pgx.common.auth.PgxResourcePermission permission)
Grants a permission on this graph to the given user.
|
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
|
boolean |
hasEdgeLabel()
Blocking version of
hasEdgeLabelAsync() . |
PgxFuture<java.lang.Boolean> |
hasEdgeLabelAsync() |
<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
|
boolean |
hasVertexLabels()
Blocking version of
hasVertexLabelsAsync() . |
PgxFuture<java.lang.Boolean> |
hasVertexLabelsAsync() |
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 |
isPinned()
Blocking version of
isPinnedAsync() . |
PgxFuture<java.lang.Boolean> |
isPinnedAsync()
For a published graph, indicates if the graph is pinned.
|
boolean |
isPublished()
Blocking version of
isPublishedAsync() . |
PgxFuture<java.lang.Boolean> |
isPublishedAsync()
Checks if this graph is published.
|
boolean |
isPublishedWithSnapshots()
Blocking version of
isPublishedWithSnapshotsAsync() . |
PgxFuture<java.lang.Boolean> |
isPublishedWithSnapshotsAsync()
Checks if this graph is published with snapshots.
|
boolean |
isTransient()
Gets the transient flag of this graph.
|
void |
pin()
Blocking version of
pinAsync() . |
PgxFuture<java.lang.Void> |
pinAsync()
For a published graph, pins the graph so that it stays published even if no sessions uses it.
|
PgxPreparedStatement |
preparePgql(java.lang.String pgqlString)
Blocking version of
preparePgql(String) . |
PgxFuture<PgxPreparedStatement> |
preparePgqlAsync(java.lang.String pgqlString)
Prepares a PGQL query.
|
void |
publish()
Blocking version of
publishAsync() . |
void |
publish(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps) |
PgxFuture<java.lang.Void> |
publishAsync()
Publishes the graph so it can be shared between sessions.
|
PgxFuture<java.lang.Void> |
publishAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps)
Publishes the graph so It can be shared between sessions.
|
void |
publishWithSnapshots()
Blocking version of
publishWithSnapshotsAsync() . |
void |
publishWithSnapshots(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps)
Blocking version of
publishWithSnapshotsAsync(Collection, Collection) . |
PgxFuture<java.lang.Void> |
publishWithSnapshotsAsync()
Publishes the graph and all its snapshots so they can be shared between sessions.
|
PgxFuture<java.lang.Void> |
publishWithSnapshotsAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps)
Publishes the graph and all its snapshots so they can be shared between sessions.
|
PgqlResultSet |
queryPgql(java.lang.String pgqlString)
Blocking version of
queryPgql(String) . |
PgxFuture<PgqlResultSet> |
queryPgqlAsync(java.lang.String pgqlString)
Submits a pattern matching select only query.
|
void |
removeRedactionRule(oracle.pgx.config.PgxRedactionRuleConfig ruleConfig, AuthorizationType type, java.lang.String... names)
Blocking version of
removeRedactionRule(PgxRedactionRuleConfig, AuthorizationType, String...) Calls removeRedactionRuleAsync(PgxRedactionRuleConfig, AuthorizationType, String...) )} and waits for the returned PgxFuture to complete. |
PgxFuture<java.lang.Void> |
removeRedactionRuleAsync(oracle.pgx.config.PgxRedactionRuleConfig ruleConfig, AuthorizationType type, java.lang.String... names)
Removes a redaction rule for AuthorizationType names.
|
void |
rename(java.lang.String newGraphName)
Blocking version of
renameAsync(String) . |
PgxFuture<java.lang.Void> |
renameAsync(java.lang.String newGraphName)
Renames this graph.
|
void |
revokePermission(oracle.pgx.common.auth.PgxRole role)
Blocking version of
revokePermissionAsync(PgxRole) . |
void |
revokePermission(oracle.pgx.common.auth.PgxUser user)
Blocking version of
revokePermissionAsync(PgxUser) . |
PgxFuture<java.lang.Void> |
revokePermissionAsync(oracle.pgx.common.auth.PgxRole role)
Revokes all permissions on this graph from the given role.
|
PgxFuture<java.lang.Void> |
revokePermissionAsync(oracle.pgx.common.auth.PgxUser user)
Revokes all permissions on this graph from the given user.
|
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 getId() |
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, FileGraphStoringConfig storingConfig)
Blocking version of
storeAsync(Format, FileGraphStoringConfig) . |
FileGraphConfig |
store(Format targetFormat, FileGraphStoringConfig storingConfig, boolean overwrite)
Blocking version of
storeAsync(Format, FileGraphStoringConfig, boolean) . |
FileGraphConfig |
store(Format targetFormat, FileGraphStoringConfig storingConfig, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(Format, FileGraphStoringConfig, Collection, Collection, boolean) . |
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) . |
FileGraphConfig |
store(Format targetFormat, java.lang.String targetBasePath, int numPartitions)
Blocking version of
storeAsync(Format, String, int) . |
FileGraphConfig |
store(Format targetFormat, java.lang.String targetBasePath, int numPartitions, boolean overwrite)
Blocking version of
storeAsync(Format, String, int, boolean) . |
FileGraphConfig |
store(Format targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(Format, String, int, Collection, Collection, boolean) . |
GraphConfig |
store(GraphConfig targetConfig, boolean overwrite)
Blocking version of
storeAsync(GraphConfig, boolean) . |
GraphConfig |
store(GraphConfig targetConfig, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite)
Blocking version of
storeAsync(GraphConfig, Set, Set, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs)
Blocking version of
storeAsync(ProviderFormat, Map, Map) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, Map, Map, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, Map, Map, Collection, Collection, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, Set, Set, Map, Map, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, Set, Set, Map, Map, Collection, Collection, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath)
Blocking version of
storeAsync(ProviderFormat, String) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, String, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, String, Collection, Collection, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions)
Blocking version of
storeAsync(ProviderFormat, String, int) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, String, int, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, String, int, Collection, Collection, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore)
Blocking version of
storeAsync(ProviderFormat, String, int, Set, Set) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, String, int, Set, Set, , boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, String, int, Set, Set, Collection, Collection, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore)
Blocking version of
storeAsync(ProviderFormat, String, Set ,Set) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, String, boolean) . |
PartitionedGraphConfig |
store(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Blocking version of
storeAsync(ProviderFormat, String, Set, Set, Collection, Collection, boolean) . |
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, FileGraphStoringConfig storingConfig)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, FileGraphStoringConfig storingConfig, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, FileGraphStoringConfig storingConfig, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
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<FileGraphConfig> |
storeAsync(Format targetFormat, java.lang.String targetBasePath, int numPartitions)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, java.lang.String targetBasePath, int numPartitions, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<FileGraphConfig> |
storeAsync(Format targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<GraphConfig> |
storeAsync(GraphConfig targetConfig, boolean overwrite)
Stores this graph in a file or database.
|
PgxFuture<GraphConfig> |
storeAsync(GraphConfig targetConfig, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite)
Stores this graph in a file or database.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath)
Stores this graph in a given file format on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, boolean overwrite)
Stores this graph in a given file format on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, 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<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Stores this graph in a given file format in multiple partitions on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore)
Stores this graph in a given file format on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite)
Stores this graph in a given file format on a file system.
|
PgxFuture<PartitionedGraphConfig> |
storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
Stores this graph in a given file format on a file system.
|
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 getId() |
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 getId() |
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 getId() |
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 |
void |
unpin()
Blocking version of
unpinAsync() . |
PgxFuture<java.lang.Void> |
unpinAsync()
For a published graph, unpins the graph so that if no snapshot of the graph is used by any session or pinned, the graph and all its snapshots can be removed.
|
hashCode
close
public void addRedactionRule(oracle.pgx.config.PgxRedactionRuleConfig ruleConfig, AuthorizationType type, java.lang.String... names)
addRedactionRule(PgxRedactionRuleConfig, AuthorizationType, String...)
Calls addRedactionRuleAsync(PgxRedactionRuleConfig, AuthorizationType, String...)
)} and waits for the returned PgxFuture
to complete.public PgxFuture<java.lang.Void> addRedactionRuleAsync(oracle.pgx.config.PgxRedactionRuleConfig ruleConfig, AuthorizationType type, java.lang.String... names)
ruleConfig
- the rule configuration to add for given namestype
- the type of the @link #AuthorizationTypenames
- the AuthorizationType users to whom the rule configuration will be addedpublic GraphAlterationBuilder alterGraph()
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 that should be kept in the mutated graph. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties that should be kept in the mutated graph. 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
public PgxGraph clone(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, java.lang.String newGraphName)
cloneAsync()
. Calls cloneAsync()
and waits for the returned PgxFuture
to complete.public PgxGraph clone(java.lang.String newGraphName)
cloneAsync(String)
. Calls cloneAsync(String)
and waits for the returned PgxFuture
to complete.public PgxGraph cloneAndExecutePgql(java.lang.String pgqlString) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
cloneAndExecutePgqlAsync(String)
. Calls cloneAndExecutePgqlAsync(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 cloneAndExecutePgql(java.lang.String pgqlString, java.lang.String graphName) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
cloneAndExecutePgqlAsync(String, String)
. Calls cloneAndExecutePgqlAsync(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 PgxFuture<PgxGraph> cloneAndExecutePgqlAsync(java.lang.String pgqlString)
pgqlString
- query string in PGQLpublic PgxFuture<PgxGraph> cloneAndExecutePgqlAsync(java.lang.String pgqlString, java.lang.String newGraphName)
pgqlString
- query string in PGQLnewGraphName
- name of the new graph. If null, a name will be generated.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> 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)
createAllPathsAsync(PgxVertex, EdgeProperty, VertexProperty, VertexProperty, VertexProperty)
. Calls createAllPathsAsync(PgxVertex, EdgeProperty, VertexProperty, VertexProperty, VertexProperty)
and waits for the returned PgxFuture
to complete.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()
IdGenerationStrategy.AUTO_GENERATED
for edge ID generation strategy Note: This is currently not supported for undirected graphs.public <ID extends java.lang.Comparable<ID>> GraphChangeSet<ID> createChangeSet(IdGenerationStrategy vertexIdGenerationStrategy, IdGenerationStrategy edgeIdGenerationStrategy)
vertexIdGenerationStrategy
- the vertices Id generation strategy to be usededgeIdGenerationStrategy
- the edges Id generation strategy to be usedpublic <ID> Partition<ID> createComponents(VertexProperty<ID,java.lang.Long> components, long numComponents)
createComponentsAsync(VertexProperty, long)
. Calls createComponentsAsync(VertexProperty, long)
and waits for returned PgxFuture
to complete.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)
createEdgePropertyAsync(PropertyType)
. Calls createEdgePropertyAsync(PropertyType)
and waits for returned PgxFuture
to complete.public <V> EdgeProperty<V> createEdgeProperty(PropertyType type, int dimension, java.lang.String name, boolean hardName)
createEdgePropertyAsync(PropertyType, int, String, boolean)
. Calls createEdgePropertyAsync(PropertyType, int, String, boolean)
and waits for returned PgxFuture
to complete.public <V> EdgeProperty<V> createEdgeProperty(PropertyType type, java.lang.String name)
createEdgePropertyAsync(PropertyType, String)
. Calls createEdgePropertyAsync(PropertyType, String)
and waits for returned PgxFuture
to complete.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()
createEdgeSequenceAsync()
. Calls createEdgeSequenceAsync()
and waits for returned PgxFuture
to complete.public EdgeSequence createEdgeSequence(java.lang.String name)
createEdgeSequenceAsync(String)
. Calls createEdgeSequenceAsync(String)
and waits for returned PgxFuture
to complete.public PgxFuture<EdgeSequence> createEdgeSequenceAsync()
public PgxFuture<EdgeSequence> createEdgeSequenceAsync(java.lang.String name)
name
- name of the edge sequence to be createdpublic EdgeSet createEdgeSet()
createEdgeSetAsync()
. Calls createEdgeSetAsync()
and waits for the returned PgxFuture
to complete.public EdgeSet createEdgeSet(java.lang.String name)
createEdgeSetAsync(String)
. Calls createEdgeSetAsync(String)
and waits for the returned PgxFuture
to complete.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)
createEdgeVectorPropertyAsync(PropertyType, int)
. Calls createEdgeVectorPropertyAsync(PropertyType, int)
and waits for returned PgxFuture
to complete.public <V> EdgeProperty<PgxVect<V>> createEdgeVectorProperty(PropertyType type, int dimension, java.lang.String name)
createEdgeVectorPropertyAsync(PropertyType, int, String)
. Calls createEdgeVectorPropertyAsync(PropertyType, int, String)
and waits for returned PgxFuture
to complete.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)
createMapAsync(PropertyType, PropertyType)
. Calls createMapAsync(PropertyType, PropertyType)
and waits for the returned PgxFuture
to complete.public <K,V> PgxMap<K,V> createMap(PropertyType keyType, PropertyType valType, java.lang.String mapName)
createMapAsync(PropertyType, PropertyType, String)
. Calls createMapAsync(PropertyType, PropertyType, String)
and waits for the returned PgxFuture
to complete.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)
createPathAsync(PgxVertex, PgxVertex, EdgeProperty, VertexProperty, VertexProperty)
. Calls createPathAsync(PgxVertex, PgxVertex, EdgeProperty, VertexProperty, VertexProperty)
and waits for the returned PgxFuture
to complete.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 <ID> PgxFuture<PgxPath<ID>> createPathAsync(VertexSequence<ID> nodeSequence, EdgeSequence edgeSequence)
PgxPath
object from a sequence of vertices and edges.nodeSequence
- the vertices to be used for the path creationedgeSequence
- the edges to be used for the path creationPgxPath
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)
createScalarAsync(PropertyType)
. Calls createScalarAsync(PropertyType)
and waits for the returned PgxFuture
to complete.public <T> Scalar<T> createScalar(PropertyType type, java.lang.String newScalarName)
createScalarAsync(PropertyType, String)
. Calls createScalarAsync(PropertyType, String)
and waits for the returned PgxFuture
to complete.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 extends Synchronizer> Synchronizer createSynchronizer(java.lang.Class<T> type) throws java.sql.SQLException
type
- implementation class of Synchronizerjava.sql.SQLException
public <T extends Synchronizer> Synchronizer createSynchronizer(java.lang.Class<T> type, java.sql.Connection conn) throws java.sql.SQLException
type
- Implementation class of Synchronizer.conn
- Connection object to RDBMS.java.sql.SQLException
- in case connection could not be created or Scn could not be retrieved.public <T> Scalar<PgxVect<T>> createVectorScalar(PropertyType type, int dimension)
createVectorScalarAsync(PropertyType, int)
. Calls createVectorScalarAsync(PropertyType, int)
and waits for the returned PgxFuture
to complete.public <T> Scalar<PgxVect<T>> createVectorScalar(PropertyType type, int dimension, java.lang.String newScalarName)
createVectorScalarAsync(PropertyType, int, String)
. Calls createVectorScalarAsync(PropertyType, int, String)
and waits for the returned PgxFuture
to complete.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)
createVertexPropertyAsync(PropertyType)
. Calls createVertexPropertyAsync(PropertyType)
and waits for returned PgxFuture
to complete.public <ID,V> VertexProperty<ID,V> createVertexProperty(PropertyType type, int dimension, java.lang.String name, boolean hardName)
createVertexPropertyAsync(PropertyType, int, String, boolean)
. Calls createVertexPropertyAsync(PropertyType, int, String, boolean)
and waits for returned PgxFuture
to complete.public <ID,V> VertexProperty<ID,V> createVertexProperty(PropertyType type, java.lang.String name)
createVertexPropertyAsync(PropertyType, String)
. Calls createVertexPropertyAsync(PropertyType, String)
and waits for returned PgxFuture
to complete.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()
createVertexSequenceAsync()
. Calls createVertexSequenceAsync()
and waits for returned PgxFuture
to complete.public <E> VertexSequence<E> createVertexSequence(java.lang.String name)
createVertexSequenceAsync(String)
. Calls createVertexSequenceAsync(String)
and waits for returned PgxFuture
to complete.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()
createVertexSetAsync()
. Calls createVertexSetAsync()
and waits for returned PgxFuture
to complete.public <E> VertexSet<E> createVertexSet(java.lang.String name)
createVertexSetAsync(String)
. Calls createVertexSetAsync(String)
and waits for returned PgxFuture
to complete.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)
createVertexVectorPropertyAsync(PropertyType, int)
. Calls createVertexVectorPropertyAsync(PropertyType, int)
and waits for returned PgxFuture
to complete.public <ID,V> VertexProperty<ID,PgxVect<V>> createVertexVectorProperty(PropertyType type, int dimension, java.lang.String name)
createVertexVectorPropertyAsync(PropertyType, int, String)
. Calls createVertexVectorPropertyAsync(PropertyType, int, String)
and waits for returned PgxFuture
to complete.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 void destroy()
destroyAsync()
. Calls destroyAsync()
and waits for the returned PgxFuture
to complete.destroy
in class Destroyable
public PgxFuture<java.lang.Void> destroyAsync()
PgxGraph
objects referencing the same graph (e.g. because you called PgxSession.getGraph(String)
multiple times with the same argument), they will ALL become invalid after calling this method; therefore, subsequent operations on ANY of them will result in an exception.destroyAsync
in class Destroyable
public void destroyEdgePropertyIfExists(java.lang.String name)
destroyEdgePropertyIfExistsAsync(String)
. Calls destroyEdgePropertyIfExistsAsync(String)
and waits for the returned PgxFuture
to complete.public PgxFuture<java.lang.Void> destroyEdgePropertyIfExistsAsync(java.lang.String name)
name
- the name of the edge property to destroypublic void destroyVertexPropertyIfExists(java.lang.String name)
destroyVertexPropertyIfExistsAsync(String)
. Calls destroyVertexPropertyIfExistsAsync(String)
and waits for the returned PgxFuture
to complete.public PgxFuture<java.lang.Void> destroyVertexPropertyIfExistsAsync(java.lang.String name)
name
- the name of the vertex property to destroypublic boolean equals(java.lang.Object obj)
equals
in class PgxManagedObject
public PgqlResultSet executePgql(java.lang.String pgqlString) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
executePgqlAsync(String)
. Calls executePgqlAsync(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<PgqlResultSet> executePgqlAsync(java.lang.String pgqlString)
pgqlString
- query string in PGQLpublic Operation explainPgql(java.lang.String pgqlString) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
explainPgql(String)
. Calls explainPgqlAsync(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<Operation> explainPgqlAsync(java.lang.String pgqlString)
pgqlString
- query string in PGQLpublic 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 that should be kept in the mutated graph. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties that should be kept in the mutated graph. 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 java.util.Map<java.lang.String,PgxCollection<? extends PgxEntity<?>,?>> getCollections()
getCollectionsAsync()
. Calls getCollectionsAsync()
and waits for returned PgxFuture
to complete.public PgxFuture<java.util.Map<java.lang.String,PgxCollection<? extends PgxEntity<?>,?>>> getCollectionsAsync()
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)
getEdgeAsync(long)
Calls getEdgeAsync(long)
and waits for the returned PgxFuture
to complete.public PgxFuture<PgxEdge> getEdgeAsync(long id)
PgxEdge
of this graph by ID.id
- the ID of the edgePgxEdge
objectpublic IdStrategy getEdgeIdStrategy()
public EdgeLabel getEdgeLabel()
getEdgeLabelAsync()
. Calls getEdgeLabelAsync()
and waits for the returned PgxFuture
to complete.public PgxFuture<EdgeLabel> getEdgeLabelAsync()
public java.util.Set<EdgeProperty<?>> getEdgeProperties()
getEdgePropertiesAsync()
. Calls getEdgePropertiesAsync()
and waits for returned PgxFuture
to complete.public PgxFuture<java.util.Set<EdgeProperty<?>>> getEdgePropertiesAsync()
public <V> EdgeProperty<V> getEdgeProperty(Namespace namespace, java.lang.String name)
getEdgePropertyAsync(Namespace, String)
. Calls getEdgePropertyAsync(Namespace, String)
and waits for returned PgxFuture
to complete.public <V> EdgeProperty<V> getEdgeProperty(java.lang.String name)
getEdgePropertyAsync(String)
. Calls getEdgePropertyAsync(String)
and waits for returned PgxFuture
to complete.public <V> PgxFuture<EdgeProperty<V>> getEdgePropertyAsync(Namespace namespace, java.lang.String name)
null
, use same semantics as getEdgePropertyAsync(String)
namespace
- the namespace in which to look up the property. Can be null, which implies same behavior as getEdgePropertyAsync(String)
name
- the name of the edge propertynull
if no such property existsjava.lang.NullPointerException
- if the passed name is nullpublic <V> PgxFuture<EdgeProperty<V>> getEdgePropertyAsync(java.lang.String name)
null
is returned.name
- the name of the edge propertynull
if no such property existsjava.lang.NullPointerException
- if the passed name is nullpublic EdgeSet getEdges()
public EdgeSet getEdges(EdgeFilter filter) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
getEdges(EdgeFilter)
. Calls getEdgesAsync(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 EdgeSet getEdges(EdgeFilter filter, java.lang.String name) throws java.lang.InterruptedException, java.util.concurrent.ExecutionException
getEdges(EdgeFilter, String)
. Calls getEdgesAsync(EdgeFilter, 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<EdgeSet> getEdgesAsync()
public <E> PgxFuture<EdgeSet> getEdgesAsync(EdgeFilter filter)
filter
- the edge filter expression used to create the edge setpublic PgxFuture<EdgeSet> getEdgesAsync(EdgeFilter filter, java.lang.String name)
filter
- the edge filter expression used to create the edge setname
- the name of the collection to be created. If NULL
, a name will be generated.public final oracle.pgx.common.PgxId getId()
public long getMemoryMb()
public GraphMetaData getMetaData()
public java.lang.String getName()
getName
in class PgxManagedObject
public long getNumEdges()
public long getNumVertices()
public <V> EdgeProperty<V> getOrCreateEdgeProperty(PropertyType type, java.lang.String name)
getOrCreateEdgePropertyAsync(PropertyType, String)
. Calls getOrCreateEdgePropertyAsync(PropertyType, String)
and waits for returned PgxFuture
to complete.public <V> PgxFuture<EdgeProperty<V>> getOrCreateEdgePropertyAsync(PropertyType type, java.lang.String name)
type
- type of property to createname
- of property to be createdpublic <V> EdgeProperty<PgxVect<V>> getOrCreateEdgeVectorProperty(PropertyType type, int dimension, java.lang.String name)
getOrCreateEdgeVectorPropertyAsync(PropertyType, int, String)
. Calls getOrCreateEdgeVectorPropertyAsync(PropertyType, int, String)
and waits for returned PgxFuture
to complete.public <V> PgxFuture<EdgeProperty<PgxVect<V>>> getOrCreateEdgeVectorPropertyAsync(PropertyType type, int dimension, java.lang.String name)
type
- type of property to createname
- of property to be createdpublic <V> PgxFuture<EdgeProperty<PgxVect<V>>> getOrCreateEdgeVertexPropertyAsync(PropertyType type, int dimension, java.lang.String name)
type
- type of property to createname
- of property to be createdpublic <ID,V> VertexProperty<ID,V> getOrCreateVertexProperty(PropertyType type, java.lang.String name)
getOrCreateVertexPropertyAsync(PropertyType, String)
. Calls getOrCreateVertexPropertyAsync(PropertyType, String)
and waits for returned PgxFuture
to complete.public <ID,V> PgxFuture<VertexProperty<ID,V>> getOrCreateVertexPropertyAsync(PropertyType type, java.lang.String name)
type
- type of property to createname
- of property to be createdpublic <ID,V> VertexProperty<ID,PgxVect<V>> getOrCreateVertexVectorProperty(PropertyType type, int dimension, java.lang.String name)
getOrCreateVertexVectorPropertyAsync(PropertyType, int, String)
. Calls getOrCreateVertexVectorPropertyAsync(PropertyType, int, String)
and waits for returned PgxFuture
to complete.public <ID,V> PgxFuture<VertexProperty<ID,PgxVect<V>>> getOrCreateVertexVectorPropertyAsync(PropertyType type, int dimension, java.lang.String name)
type
- type of property to createname
- of property to be createdpublic ServerInstance getPgxInstance()
public PgxEdge getRandomEdge()
getRandomEdgeAsync()
. Calls getRandomEdgeAsync()
and waits for returned PgxFuture
to complete.public PgxFuture<PgxEdge> getRandomEdgeAsync()
public <ID> PgxVertex<ID> getRandomVertex()
getRandomVertexAsync()
. Calls getRandomVertexAsync()
and waits for returned PgxFuture
to complete.public <ID> PgxFuture<PgxVertex<ID>> getRandomVertexAsync()
public java.util.List<oracle.pgx.config.PgxRedactionRuleConfig> getRedactionRules(AuthorizationType type, java.lang.String name)
getRedactionRules(AuthorizationType, String)
Calls getRedactionRulesAsync(AuthorizationType, String)
)} and waits for the returned PgxFuture
to complete.public PgxFuture<java.util.List<oracle.pgx.config.PgxRedactionRuleConfig>> getRedactionRulesAsync(AuthorizationType type, java.lang.String name)
type
- the type of the @link #AuthorizationTypename
- the AuthorizationType user from whom rules will be returnedpublic PgxSession getSession()
public <ID> PgxVertex<ID> getVertex(ID id)
getVertexAsync(Object)
. Calls getVertexAsync(Object)
and waits for the returned PgxFuture
to complete.public <ID> PgxFuture<PgxVertex<ID>> getVertexAsync(ID id)
PgxVertex
of this graph by ID.id
- the ID of the vertexPgxVertex
objectpublic IdStrategy getVertexIdStrategy()
public IdType getVertexIdType()
public <ID> VertexLabels<ID> getVertexLabels()
getVertexLabelsAsync()
. Calls getVertexLabelsAsync()
and waits for the returned PgxFuture
to complete.public <ID> PgxFuture<VertexLabels<ID>> getVertexLabelsAsync()
public java.util.Set<VertexProperty<?,?>> getVertexProperties()
getVertexPropertiesAsync()
. Calls getVertexPropertiesAsync()
and waits for returned PgxFuture
to complete.public PgxFuture<java.util.Set<VertexProperty<?,?>>> getVertexPropertiesAsync()
public <ID,V> VertexProperty<ID,V> getVertexProperty(Namespace namespace, java.lang.String name)
getVertexPropertyAsync(Namespace, String)
. Calls getVertexPropertyAsync(Namespace, String)
and waits for returned PgxFuture
to complete.public <ID,V> VertexProperty<ID,V> getVertexProperty(java.lang.String name)
getVertexPropertyAsync(String)
. Calls getVertexPropertyAsync(String)
and waits for returned PgxFuture
to complete.public <ID,V> PgxFuture<VertexProperty<ID,V>> getVertexPropertyAsync(Namespace namespace, java.lang.String name)
null
, use same semantics as getVertexPropertyAsync(String)
namespace
- the namespace in which to look up the property. Can be null, which implies same behavior as getVertexPropertyAsync(String)
name
- the name of the vertex propertynull
if no such property existsjava.lang.NullPointerException
- if the passed name is nullpublic <ID,V> PgxFuture<VertexProperty<ID,V>> getVertexPropertyAsync(java.lang.String name)
null
is returned.name
- the name of the vertex propertynull
if no such property existsjava.lang.NullPointerException
- if the passed name is nullpublic <E> VertexSet<E> getVertices()
getVerticesAsync()
. Calls getVerticesAsync()
and waits for returned PgxFuture
to complete.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 void grantPermission(oracle.pgx.common.auth.PgxRole role, oracle.pgx.common.auth.PgxResourcePermission permission)
grantPermissionAsync(PgxRole, PgxResourcePermission)
. Calls grantPermissionAsync(PgxRole, PgxResourcePermission)
and waits for the returned PgxFuture
to complete.public void grantPermission(oracle.pgx.common.auth.PgxUser user, oracle.pgx.common.auth.PgxResourcePermission permission)
grantPermissionAsync(PgxUser, PgxResourcePermission)
. Calls grantPermissionAsync(PgxUser, PgxResourcePermission)
and waits for the returned PgxFuture
to complete.public PgxFuture<java.lang.Void> grantPermissionAsync(oracle.pgx.common.auth.PgxRole role, oracle.pgx.common.auth.PgxResourcePermission permission)
PgxResourcePermission.MANAGE
.role
- the role the permission is granted topermission
- the permissionpublic PgxFuture<java.lang.Void> grantPermissionAsync(oracle.pgx.common.auth.PgxUser user, oracle.pgx.common.auth.PgxResourcePermission permission)
PgxResourcePermission.MANAGE
.user
- the user the permission is granted topermission
- the permissionpublic boolean hasEdge(long id)
hasEdgeAsync(long)
Calls hasEdgeAsync(long)
and waits for the returned PgxFuture
to complete.public PgxFuture<java.lang.Boolean> hasEdgeAsync(long id)
id
- the ID of the edgepublic boolean hasEdgeLabel()
hasEdgeLabelAsync()
. Calls hasEdgeLabelAsync()
and waits for returned PgxFuture
to complete.public PgxFuture<java.lang.Boolean> hasEdgeLabelAsync()
true
if the graph has edge labels, false
if notpublic <ID> boolean hasVertex(ID id)
hasVertexAsync(Object)
. Calls hasVertexAsync(Object)
and waits for the returned PgxFuture
to complete.public <ID> PgxFuture<java.lang.Boolean> hasVertexAsync(ID id)
id
- the ID of the vertexpublic boolean hasVertexLabels()
hasVertexLabelsAsync()
. Calls hasVertexLabelsAsync()
and waits for returned PgxFuture
to complete.public PgxFuture<java.lang.Boolean> hasVertexLabelsAsync()
true
if the graph has vertex labels, false
if notpublic 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 isPinned()
isPinnedAsync()
. Calls isPinnedAsync()
and waits for returned PgxFuture
to complete.public PgxFuture<java.lang.Boolean> isPinnedAsync()
public boolean isPublished()
isPublishedAsync()
. Calls isPublishedAsync()
and waits for returned PgxFuture
to complete.public PgxFuture<java.lang.Boolean> isPublishedAsync()
true
if this graph is published, false
otherwise.public boolean isPublishedWithSnapshots()
isPublishedWithSnapshotsAsync()
. Calls isPublishedWithSnapshotsAsync()
and waits for returned PgxFuture
to complete.public PgxFuture<java.lang.Boolean> isPublishedWithSnapshotsAsync()
true
if this graph is published, false
otherwise.public boolean isTransient()
true
if this graph is transient (session-bound, private), false
otherwise.public void pin()
public PgxFuture<java.lang.Void> pinAsync()
public PgxPreparedStatement preparePgql(java.lang.String pgqlString)
preparePgql(String)
. Calls preparePgqlAsync(String)
and waits for the returned PgxFuture
to complete.public PgxFuture<PgxPreparedStatement> preparePgqlAsync(java.lang.String pgqlString)
pgqlString
- query string in PGQLpublic void publish()
publishAsync()
. Calls publishAsync()
and waits for returned PgxFuture
to complete.public void publish(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps)
public PgxFuture<java.lang.Void> publishAsync()
public PgxFuture<java.lang.Void> publishAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps)
vertexProps
- list of vertex properties belonging to graph specified by graph to be published as well. Constants Properties.ALL
or Properties.NONE
can be used.edgeProps
- list of edge properties belonging to graph specified by graph to be published as well. Constants Properties.ALL
or Properties.NONE
can be used.public void publishWithSnapshots()
publishWithSnapshotsAsync()
. Calls publishWithSnapshotsAsync()
and waits for returned PgxFuture
to complete.public void publishWithSnapshots(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps)
publishWithSnapshotsAsync(Collection, Collection)
. Calls publishWithSnapshotsAsync(Collection, Collection)
and waits for returned PgxFuture
to complete.public PgxFuture<java.lang.Void> publishWithSnapshotsAsync()
public PgxFuture<java.lang.Void> publishWithSnapshotsAsync(java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps)
vertexProps
- list of vertex properties belonging to graph specified by graph to be published as well. Constants Properties.ALL
or Properties.NONE
can be used.edgeProps
- list of edge properties belonging to graph specified by graph to be published as well. Constants Properties.ALL
or Properties.NONE
can be used.public PgqlResultSet queryPgql(java.lang.String pgqlString) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
queryPgql(String)
. Calls queryPgqlAsync(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<PgqlResultSet> queryPgqlAsync(java.lang.String pgqlString)
pgqlString
- query string in PGQLpublic void removeRedactionRule(oracle.pgx.config.PgxRedactionRuleConfig ruleConfig, AuthorizationType type, java.lang.String... names)
removeRedactionRule(PgxRedactionRuleConfig, AuthorizationType, String...)
Calls removeRedactionRuleAsync(PgxRedactionRuleConfig, AuthorizationType, String...)
)} and waits for the returned PgxFuture
to complete.public PgxFuture<java.lang.Void> removeRedactionRuleAsync(oracle.pgx.config.PgxRedactionRuleConfig ruleConfig, AuthorizationType type, java.lang.String... names)
ruleConfig
- the rule configuration to remove for given namestype
- the type of the @link #AuthorizationTypenames
- the AuthorizationType users to whom the rule configuration will be removedpublic void rename(java.lang.String newGraphName)
renameAsync(String)
. Calls renameAsync(String)
and waits for the returned PgxFuture
to complete.public PgxFuture<java.lang.Void> renameAsync(java.lang.String newGraphName)
newGraphName
- the new name.public void revokePermission(oracle.pgx.common.auth.PgxRole role)
revokePermissionAsync(PgxRole)
. Calls revokePermissionAsync(PgxRole)
and waits for the returned PgxFuture
to complete.public void revokePermission(oracle.pgx.common.auth.PgxUser user)
revokePermissionAsync(PgxUser)
. Calls revokePermissionAsync(PgxUser)
and waits for the returned PgxFuture
to complete.public PgxFuture<java.lang.Void> revokePermissionAsync(oracle.pgx.common.auth.PgxRole role)
role
- the role for which all permissions will be revoked frompublic PgxFuture<java.lang.Void> revokePermissionAsync(oracle.pgx.common.auth.PgxUser user)
user
- the user for which all permissions will be revoked frompublic 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 getId()public 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 that should be kept in the mutated graph. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties that should be kept in the mutated graph. 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 that should be kept in the mutated graph. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties that should be kept in the mutated graph. 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, FileGraphStoringConfig storingConfig) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(Format, FileGraphStoringConfig)
. Calls storeAsync(Format, FileGraphStoringConfig)
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, FileGraphStoringConfig storingConfig, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(Format, FileGraphStoringConfig, boolean)
. Calls storeAsync(Format, FileGraphStoringConfig, 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, FileGraphStoringConfig storingConfig, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(Format, FileGraphStoringConfig, Collection, Collection, boolean)
. Calls storeAsync(Format, FileGraphStoringConfig, 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 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 FileGraphConfig store(Format targetFormat, java.lang.String targetBasePath, int numPartitions) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(Format, String, int)
. Calls storeAsync(Format, String, 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 FileGraphConfig store(Format targetFormat, java.lang.String targetBasePath, int numPartitions, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(Format, String, int, boolean)
. Calls storeAsync(Format, String, int, 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 targetBasePath, int numPartitions, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(Format, String, int, Collection, Collection, boolean)
. Calls storeAsync(Format, String, int, 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 GraphConfig store(GraphConfig targetConfig, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(GraphConfig, Set, Set, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, Map, Map)
. Calls storeAsync(ProviderFormat, Map, Map)
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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, Map, Map, boolean)
. Calls storeAsync(ProviderFormat, Map, Map, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, Map, Map, Collection, Collection, boolean)
. Calls storeAsync(ProviderFormat, Map, Map, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, Set, Set, Map, Map, boolean)
. Calls storeAsync(ProviderFormat, Map, Map, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, Set, Set, Map, Map, Collection, Collection, boolean)
. Calls storeAsync(ProviderFormat, Map, Map, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String)
. Calls storeAsync(ProviderFormat, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String, int)
. Calls storeAsync(ProviderFormat, String, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String, int, boolean)
. Calls storeAsync(ProviderFormat, String, int, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String, int, Collection, Collection, boolean)
. Calls storeAsync(ProviderFormat, String, int, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String, int, Set, Set)
. Calls storeAsync(ProviderFormat, String, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String, int, Set, Set, , boolean)
. Calls storeAsync(ProviderFormat, String, int, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String, int, Set, Set, Collection, Collection, boolean)
. Calls storeAsync(ProviderFormat, String, int, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String, Set ,Set)
. Calls storeAsync(ProviderFormat, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String, boolean)
. Calls storeAsync(ProviderFormat, String, Set, Set, 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 PartitionedGraphConfig store(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite) throws java.util.concurrent.ExecutionException, java.lang.InterruptedException
storeAsync(ProviderFormat, String, Set, Set, 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 PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, FileGraphStoringConfig storingConfig)
store(Format, FileGraphStoringConfig, boolean)
, setting the overwrite flag to false
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.storingConfig
- the storing configuration to use for writing the graph.public PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, FileGraphStoringConfig storingConfig, boolean overwrite)
storeAsync(Format, FileGraphStoringConfig, 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 file formats with vertices and edge combined in same file are supported.storingConfig
- the storing configuration to use for writing the 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 PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, FileGraphStoringConfig storingConfig, 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.storingConfig
- the storing configuration to use for writing the graph.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<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 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.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 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.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<FileGraphConfig> storeAsync(Format targetFormat, java.lang.String targetBasePath, int numPartitions)
store(Format, String, int, boolean)
, setting the overwrite flag to false
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.targetBasePath
- the base path to use for writing the graph. Use schemes to write to a specific file system.numPartitions
- the number of partitions in which to write the graph.public PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, java.lang.String targetBasePath, int numPartitions, boolean overwrite)
storeAsync(Format, String, int, 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 file formats with vertices and edge combined in same file are supported.targetBasePath
- the base path to use for writing the graph. Use schemes to write to a specific file system.numPartitions
- the number of partitions in which to write the 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 PgxFuture<FileGraphConfig> storeAsync(Format targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
storeAsync(Format, FileGraphStoringConfig, Collection, Collection, boolean)
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.targetBasePath
- the base path to use for writing the graph. Use schemes to write to a specific file system.numPartitions
- the number of partitions in which to write the graph.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 PgxFuture<GraphConfig> storeAsync(GraphConfig targetConfig, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite)
targetConfig
- the graph configuration describing the stored graph.vertexProvidersToStore
- for partitioned graphs, the vertex providers to storeedgeProvidersToStore
- for partitioned graphs, the edge providers to storeoverwrite
- 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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs)
storeAsync(ProviderFormat, Map, Map, boolean)
, setting the overwrite flag to false
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.vertexStoringConfigs
- the storing configurations to use for writing the vertices from the vertex providers.edgeStoringConfigs
- the storing configurations to use for writing the edges from the edge providers.public PgxFuture<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, boolean overwrite)
storeAsync(ProviderFormat, Map, Map, 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 file formats with vertices and edge combined in same file are supported.vertexStoringConfigs
- the storing configurations to use for writing the vertices from the vertex providers.edgeStoringConfigs
- the storing configurations to use for writing the edges from the edge providers.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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, 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.vertexStoringConfigs
- the storing configurations to use for writing the vertices from the vertex providers.edgeStoringConfigs
- the storing configurations to use for writing the edges from the edge providers.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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, boolean overwrite)
storeAsync(ProviderFormat, Map, Map, 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 file formats with vertices and edge combined in same file are supported.vertexProvidersToStore
- for partitioned graphs, the vertex providers to storeedgeProvidersToStore
- for partitioned graphs, the edge providers to storevertexStoringConfigs
- the storing configurations to use for writing the vertices from the vertex providers.edgeStoringConfigs
- the storing configurations to use for writing the edges from the edge providers.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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Map<java.lang.String,FileGraphStoringConfig> vertexStoringConfigs, java.util.Map<java.lang.String,FileGraphStoringConfig> edgeStoringConfigs, 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.vertexProvidersToStore
- for partitioned graphs, the vertex providers to storeedgeProvidersToStore
- for partitioned graphs, the edge providers to storevertexStoringConfigs
- the storing configurations to use for writing the vertices from the vertex providers.edgeStoringConfigs
- the storing configurations to use for writing the edges from the edge providers.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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath)
store(ProviderFormat, String, boolean)
, setting the overwrite flag to false
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.targetBasePath
- the path the graph should be written to. Use schemes to write to a specific file system.public PgxFuture<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, boolean overwrite)
storeAsync(ProviderFormat, 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 file formats with vertices and edge combined in same file are supported.targetBasePath
- 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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, 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.targetBasePath
- 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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions)
storeAsync(ProviderFormat, String, int, boolean)
, setting the overwrite flag to false
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.targetBasePath
- the base path to use for writing the graph. Use schemes to write to a specific file system.numPartitions
- the number of partitions in which to write the graph.public PgxFuture<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, boolean overwrite)
storeAsync(ProviderFormat, String, int, 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 file formats with vertices and edge combined in same file are supported.targetBasePath
- the base path to use for writing the graph. Use schemes to write to a specific file system.numPartitions
- the number of partitions in which to write the 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 PgxFuture<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
storeAsync(ProviderFormat, String, int, Set, Set, Map, Map, Collection, Collection, boolean)
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.targetBasePath
- the base path to use for writing the graph. Use schemes to write to a specific file system.numPartitions
- the number of partitions in which to write the graph.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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore)
storeAsync(ProviderFormat, String, int, boolean)
, setting the overwrite flag to false
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.targetBasePath
- the base path to use for writing the graph. Use schemes to write to a specific file system.numPartitions
- the number of partitions in which to write the graph.vertexProvidersToStore
- for partitioned graphs, the vertex providers to storeedgeProvidersToStore
- for partitioned graphs, the edge providers to storepublic PgxFuture<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite)
storeAsync(ProviderFormat, String, int, 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 file formats with vertices and edge combined in same file are supported.targetBasePath
- the base path to use for writing the graph. Use schemes to write to a specific file system.numPartitions
- the number of partitions in which to write the graph.vertexProvidersToStore
- the vertex providers to storeedgeProvidersToStore
- the edge providers to storeoverwrite
- 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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, int numPartitions, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, java.util.Collection<VertexProperty<?,?>> vertexProps, java.util.Collection<EdgeProperty<?>> edgeProps, boolean overwrite)
storeAsync(ProviderFormat, String, int, Set, Set, Map, Map, Collection, Collection, boolean)
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.targetBasePath
- the base path to use for writing the graph. Use schemes to write to a specific file system.numPartitions
- the number of partitions in which to write the graph.vertexProvidersToStore
- the vertex providers to storeedgeProvidersToStore
- the edge providers to storevertexProps
- 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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore)
store(ProviderFormat, String, boolean)
, setting the overwrite flag to false
.targetFormat
- the format in which to store this graph. Note that only file formats with vertices and edge combined in same file are supported.targetBasePath
- the path the graph should be written to. Use schemes to write to a specific file system.vertexProvidersToStore
- for partitioned graphs, the vertex providers to storeedgeProvidersToStore
- for partitioned graphs, the edge providers to storepublic PgxFuture<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, boolean overwrite)
storeAsync(ProviderFormat, 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 file formats with vertices and edge combined in same file are supported.targetBasePath
- the path the graph should be written to. Use schemes to write to a specific file system.vertexProvidersToStore
- the vertex providers to storeedgeProvidersToStore
- the edge providers to storeoverwrite
- 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<PartitionedGraphConfig> storeAsync(ProviderFormat targetFormat, java.lang.String targetBasePath, java.util.Set<java.lang.String> vertexProvidersToStore, java.util.Set<java.lang.String> edgeProvidersToStore, 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.targetBasePath
- the path the graph should be written to. Use schemes to write to a specific file system.vertexProvidersToStore
- for partitioned graphs, the vertex providers to storeedgeProvidersToStore
- for partitioned graphs, the edge providers to storevertexProps
- 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 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 getId()public 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 that should be kept in the mutated graph. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties that should be kept in the mutated graph. 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 getId()public 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 getId()public 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 that should be kept in the mutated graph. Constants VertexProperty.ALL
or VertexProperty.NONE
can be used.edgeProps
- edge properties that should be kept in the mutated graph. 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.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.public void unpin()
public PgxFuture<java.lang.Void> unpinAsync()