Object/Class

com.datastax.bdp.graph.spark.graphframe

DseGraphFrame

Related Docs: class DseGraphFrame | package graphframe

Permalink

object DseGraphFrame extends Serializable

Linear Supertypes
Serializable, Serializable, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DseGraphFrame
  2. Serializable
  3. Serializable
  4. AnyRef
  5. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. val DstColumnName: String

    Permalink
  5. val EdgeIdColumnNames: Seq[String]

    Permalink
  6. val GFColumnNames: Seq[String]

    Permalink
  7. val IdColumnName: String

    Permalink
  8. val IdFieldsSeparator: String

    Permalink

    vertex label in id separator Vertex id has format vertex_label:base64(idColumns)

  9. val LabelColumnName: String

    Permalink
  10. val SrcColumnName: String

    Permalink
  11. val SystemColumnNames: Seq[String]

    Permalink
  12. val UpdateDfPersistLevelParam: String

    Permalink

    the updateVertices, deleteVertexProperties, deleteVertices methods cache id dataframe and edge data frames for consistency "spark.dse.graphframes.update.persistLevel" spark configuration parameter can be used to change default MEMORY_ONLY storage to other spark levels.

  13. def addAdjVertexIdColumns(df: DataFrame, dstColumn: Column, schema: SerializableSchema): DataFrame

    Permalink

    add: ~adjacent_vertex_id ~~adjacent_label_id

  14. def addEdgeLabelColumns(df: DataFrame, label: Column, direction: Direction, schema: SerializableSchema): DataFrame

    Permalink
  15. def addNaturalVertexIdColumns(df: DataFrame, label: String, schema: SerializableSchema, id: Column): DataFrame

    Permalink
  16. def adjVertexLabelUdf(schema: SerializableSchema): UserDefinedFunction

    Permalink

    UDF that extract dst vertex label

  17. def apply(graphFrame: GraphFrame, dabaseName: String, schema: SerializableSchema): DseGraphFrame

    Permalink

    DseGraphFrameBuilder.dseGraph should be used instead of this

  18. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  19. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  20. def edgeLabelNameColumn(schema: SerializableSchema): Column

    Permalink

    returns

    UDF that extract label name from the edgeLabelId

  21. def edgeLabelNameUdf(schema: SerializableSchema): UserDefinedFunction

    Permalink
  22. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  23. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  24. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  25. def fromGfName(name: String): String

    Permalink
  26. def fromGfNames(df: DataFrame): DataFrame

    Permalink
  27. val fromGfNamesRegex: Regex

    Permalink
  28. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  29. def getSchemaFromServer(graphName: String, connector: CassandraConnector): SerializableSchema

    Permalink
  30. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  31. def hiveQuote(columns: Seq[String]): Seq[String]

    Permalink
  32. def hiveQuote(column: String): String

    Permalink
  33. def hiveQuoteColumn(name: String): Column

    Permalink
  34. def idSqlSchema(props: Seq[Property]): StructType

    Permalink
  35. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  36. def naturalEdgeLabelUdf(direction: Direction, schema: SerializableSchema): UserDefinedFunction

    Permalink
  37. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  38. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  39. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  40. def sqlSchema(props: Seq[Property]): StructType

    Permalink

    get SQL schema for given properties

  41. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  42. def syntheticAdjVertexIdColumn(schema: SerializableSchema): Column

    Permalink

    calculate dst column from ADJACENT_VERTEX_ID column.

    calculate dst column from ADJACENT_VERTEX_ID column. It should match focalVertexId format: label:base64(columnIds)

  43. def syntheticAdjVertexLabelUdf(schema: SerializableSchema): UserDefinedFunction

    Permalink

    UDF that extract dst vertex label

  44. def syntheticNonStandardIdUdf(idColumnContainer: ColumnContainer, rowWriter: RowWriter[Row]): UserDefinedFunction

    Permalink

    udf function for non standard id

  45. def syntheticStandardIdUdf: UserDefinedFunction

    Permalink

    idf function for standard id

  46. def syntheticVertexIdColumn(label: String, hasStandardId: Boolean, idSqlColumns: Seq[Column], idColumnContainer: ColumnContainer, rowWriter: RowWriter[Row]): Column

    Permalink
  47. def syntheticVertexIdColumn(label: String, schema: SerializableSchema, idSqlColumns: Seq[Column]): Column

    Permalink

    Vertex id has format vertexLabel:base64(idColumns)

  48. def toArrayVertexId(id: String, vertex: Vertex): Array[AnyRef]

    Permalink

    id

    in form "label:encode64(data)"

    vertex

    with column mapping

  49. def toExternalEdgeId(label: String, srcId: String, dstId: String, uuid: UUID, schema: SerializableSchema): Map[String, AnyRef]

    Permalink

    expected output will be: {~label=edge, ~out_vertex={~label=vertex, community_id=1888030080, member_id=0}, ~in_vertex={~label=custom, name=Name, array=1}, ~local_id=2f3671c0-96d0-11e6-9882-f74edf21f349}

  50. def toExternalVertexId(id: String, schema: SerializableSchema): AbstractVertexIdExternalImpl

    Permalink

    id

    in form "label:encode64(data)"

    schema

    graph schema

    returns

    ExternalId object

  51. def toGfColumn(name: String): Column

    Permalink
  52. def toGfName(name: String): String

    Permalink
  53. val toGfNamesRegex: Regex

    Permalink
  54. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  55. def vertexNonStandardIdUdf(vertex: Vertex): UserDefinedFunction

    Permalink

    restore vertex Id from the GraphFrame Vertex id

  56. def vertexStandardIdUdf: UserDefinedFunction

    Permalink

    restore vertex Id from the GraphFrame Vertex id

  57. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  58. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  59. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped