com.datastax.bdp.graph.spark.graphframe
BasicDseGraphFrame
Related Doc:
package graphframe
Return graph traversal that supports a subset of TinkerPop3 traversal steps
Return graph traversal that supports a subset of TinkerPop3 traversal steps
to start traverse with
GraphTraversal[Edge] for the filtered graph
Return graph traversal that supports a subset of TinkerPop3 traversal steps
Return graph traversal that supports a subset of TinkerPop3 traversal steps
GraphTraversal[Edge] for the graph
Return graph traversal that supports subset of TinkerPop3 traversal steps
Return graph traversal that supports subset of TinkerPop3 traversal steps
to start traverse with
GraphTraversal[Vertex] for the filtered graph
Return graph traversal that supports subset of TinkerPop3 traversal steps
Return graph traversal that supports subset of TinkerPop3 traversal steps
GraphTraversal[Vertex] for the graph
proxy call to gf.cache()
Remove any invalid edge entries from the database backend.
Remove any invalid edge entries from the database backend.
that could be a sub-graph of the original graphframe
new DseGraphFrame with the same schema but with new provided graph frame data
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
delete only selected properties not entire row
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
data frame with edge ids: src,dst,~label, id
cache df before processing, true by default for consistence updates. two C* entries need to be deleted for one edge, so no reloads expected between this two calls.
shortcut for deleteEdges(df: DataFrame, cache: Boolean = true) for Java
shortcut for deleteEdges(df: DataFrame, cache: Boolean = true) for Java
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
property names to delete
clean vertex properties with meta properties
clean vertex properties with meta properties
property names to delete
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
proxy call to gf.dropIsolatedVertices()
proxy call to gf.dropIsolatedVertices()
new filtered DseGraphFrame
proxy call to gf.filterEdges()
proxy call to gf.filterEdges()
proxy call to gf.filterVertices()
proxy call to gf.filterVertices()
Returns the graph name of this DseGraphFrame.
Returns the graph name of this DseGraphFrame.
NoSuchElementException if the graph name is not set.
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
Performs a read or write based operation on the Graph backing this GraphTraversalSource.
Performs a read or write based operation on the Graph backing this GraphTraversalSource. This
step can be accompanied by the Object) modulator for further configuration
and must be accompanied by a GraphTraversal#read() or GraphTraversal#write() modulator step
which will terminate the traversal.
the url of file in distributed file system or JDBC connection or the name of file in default file system for which the read or write will apply - note that the context of how this parameter is used is wholly dependent on the implementation. i.e cassandra read/writer implementation will ignore this path and read table name from parameters.
the traversal with the { @link IoStep} added
proxy call to gf.persist()
proxy call to gf.persist()
Edge label
Source vertex id
Destination vertex id
Edge ids
Associated DataFrame schema
External ID object
String of vertex ID
External ID object
proxy call to gf.unpersist()
proxy call to gf.unpersist()
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
data frame with edge ids and update columns
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
data frame with edge ids and update columns
cache df before processing, true by default for consistence updates. two C* entries need to be updated for one edge, so no reloads expected between this two calls.
shortcut for updateEdges(df: DataFrame, cache: Boolean = true) for Java
shortcut for updateEdges(df: DataFrame, cache: Boolean = true) for Java
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
vertex label to update
dataframe with vertex ids and columns to update
The graph is read-only.
The graph is read-only. Method throws NotImplementedError
dataframe with vertex id and update columns
empty (means all) by default, it is convenient to group vertexes with the same id format. That group could be passed here, to reduce number of verification steps
cache df before processing, true by default for consistence update and performance
shortcut for updateVertices(df: DataFrame, labels: Seq[String] = Seq.empty, cache: Boolean = true) for Java API
shortcut for updateVertices(df: DataFrame, labels: Seq[String] = Seq.empty, cache: Boolean = true) for Java API
dataframe with vertex id and update columns
Minimal read only DseGraphFrame implementation that wraps a GraphFrame to run traversal. Update and delete methods are not supported and will throw a NotImplementedError.