graphframe

Type Members

class BasicDseGraphFrame extends DseGraphFrame

Minimal read only DseGraphFrame implementation that wraps a GraphFrame to run traversal.
Minimal read only DseGraphFrame implementation that wraps a GraphFrame to run traversal. Update and delete methods are not supported and will throw a NotImplementedError.
class DGFCleaner extends AnyRef
class DGFCleanerInterceptor extends SparkVertexProgramInterceptor[CleanGraphVertexProgram]
class DGFCleanupStats extends AnyRef
abstract class DseGraphFrame extends Serializable

Provides DSE Graph-specific methods on GraphFrames.
Provides DSE Graph-specific methods on GraphFrames. A DseGraphFrame requires a graphName for creating some traversal steps and for writing data back to DSE. Implicit conversions ensure the graphName is preserved or reassigned since it can be lost during a DseGraphFrame->GraphFrame->DseGraphFrame transition chain.
abstract class DseGraphFrameBuilder extends AnyRef
class DseGraphTraversal[E] extends DefaultGraphTraversal[Row, E]

wrap vertex data frame to implement TinkerPop functions
class SparkSessionFunctions extends Serializable

Provides DSE-specific methods on SparkSession

Value Members

object DGFCleaner
object DseGraphFrame extends Serializable
object DseGraphFrameBuilder

Usage: val dataFrame = DseGraphFrameBuilder("graph", spark).dataFrame()
object DseGraphMigration
object DseGraphSchemaMigration

object Order

The spark-shell show may show an "ambiguous reference to overloaded definition" error for two functions: GraphTraversal.by(Order) and GraphTraversal.by(Comparable)

Here is an example:

scala>  g.V().values("name").order().by(Order.decr)
console>:43: error: ambiguous reference to overloaded definition,
both method by in trait GraphTraversal of type (x$1: org.apache.tinkerpop.gremlin.process.traversal.Order)org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal[org.apache.spark.sql.Row,E2]
and  method by in trait GraphTraversal of type (x$1: java.util.Comparator[E2])org.apache.tinkerpop.gremlin.process.traversal.dsl.graph.GraphTraversal[org.apache.spark.sql.Row,E2]
match argument types (org.apache.tinkerpop.gremlin.process.traversal.Order)

To workaround this problem a user can directly cast Order to super class: Comparable

scala> g.V().values("name").order().by(Order.decr.asInstanceOf[Order])

This is an inconvenient workaround, so this class replicates the Order interface but returns Comparable instead of Order. Users should import this object to avoid the aforementioned issues.

object VertexLabelDropInterceptor extends DseGraphTraversalInterceptor
implicit def backToDseVertexFrame[E](gt: GraphTraversal[Row, E]): DseGraphTraversal[E]
package classic
package dsedb
implicit def fromDseGraphFrame(gf: DseGraphFrame): GraphFrame
implicit def fromVertexFrame[E](gt: GraphTraversal[Row, E]): DataFrame

add all DataFrame functions to DseGraphTraversal
package optimizer
implicit def toDseGraphFrame(gf: GraphFrame): DseGraphFrame
implicit def toSparkSessionFunctions(spark: SparkSession): SparkSessionFunctions

package graphframe

Type Members

class BasicDseGraphFrame extends DseGraphFrame

class DGFCleaner extends AnyRef

class DGFCleanerInterceptor extends SparkVertexProgramInterceptor[CleanGraphVertexProgram]

class DGFCleanupStats extends AnyRef

abstract class DseGraphFrame extends Serializable

abstract class DseGraphFrameBuilder extends AnyRef

class DseGraphTraversal[E] extends DefaultGraphTraversal[Row, E]

class SparkSessionFunctions extends Serializable

Value Members

object DGFCleaner

object DseGraphFrame extends Serializable

object DseGraphFrameBuilder

object DseGraphMigration

object DseGraphSchemaMigration

object Order

object VertexLabelDropInterceptor extends DseGraphTraversalInterceptor

implicit def backToDseVertexFrame[E](gt: GraphTraversal[Row, E]): DseGraphTraversal[E]

package classic

package dsedb

implicit def fromDseGraphFrame(gf: DseGraphFrame): GraphFrame

implicit def fromVertexFrame[E](gt: GraphTraversal[Row, E]): DataFrame

package optimizer

implicit def toDseGraphFrame(gf: GraphFrame): DseGraphFrame

implicit def toSparkSessionFunctions(spark: SparkSession): SparkSessionFunctions

Inherited from AnyRef

Inherited from Any

Ungrouped