Package

com.datastax.bdp.graph

spark

Permalink

package spark

Visibility
  1. Public
  2. All

Type Members

  1. class DriverIdExtractor extends AbstractFunction1[Row, AnyRef] with RowReader[AnyRef] with (Row) ⇒ AnyRef

    Permalink
  2. class DriverIdExtractorFactory extends RowReaderFactory[AnyRef]

    Permalink
  3. class DseGraphRpc extends AnyRef

    Permalink
  4. class EdgeAndPropertyFlattener extends SchemaAndTinkerGraph with FlatMapFunction[(Seq[Row], Seq[Row]), (AnyRef, VertexWritable)]

    Permalink
  5. trait FocalVertexIdFactory extends AnyRef

    Permalink
  6. class IdentityRowReader extends RowReader[Row]

    Permalink
  7. class IdentityRowReaderFactory extends RowReaderFactory[Row]

    Permalink
  8. class MiniSchema extends Serializable with FocalVertexIdFactory

    Permalink
  9. class SerializableSchema extends Serializable with Cloneable

    Permalink
  10. class SparkSnapshotBuilderImpl extends SnapshotBuilder

    Permalink
  11. class UnsupportedTypeException extends RuntimeException

    Permalink
  12. class VertexInputRDD extends InputRDD with GraphFilterAware

    Permalink

Value Members

  1. package graphframe

    Permalink

    The root package of DSE GraphFrame support.

    The root package of DSE GraphFrame support. Offers handy implicit conversions that add DSE-specific methods to SparkSession and GraphFrame.

    Call dseGraph method on the SparkSession object to create a GraphFrame exposing DSE Graph as Spark GraphFrame.

    Example:

    import com.datastax.bdp.graph.spark.graphframe._
    
    val graphName = "test"
    // Read graph and print vertices labels:
    val graph = spark.dseGraph(graphName)
    graph.V().select("label").distinct.show
  2. package io

    Permalink
  3. package sql

    Permalink

Ungrouped