DseGraphFrame

Value Members

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

   

   Definition Classes

   AnyRef → Any

2. final def ##(): Int

   

   Definition Classes

   AnyRef → Any

3. final def ==(arg0: Any): Boolean

   

   Definition Classes

   AnyRef → Any

4. val DstColumnName: String

   

5. val EdgeIdColumnNames: Seq[String]

   

6. val GFColumnNames: Seq[String]

   

7. val IdColumnName: String

   

8. val IdFieldsSeparator: String

   

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

9. val LabelColumnName: String

   

10. val SrcColumnName: String

    

11. val SystemColumnNames: Seq[String]

    

12. val UpdateDfPersistLevelParam: String

    

    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

    

    add: ~adjacent_vertex_id ~~adjacent_label_id

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

    

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

    

16. def adjVertexLabelUdf(schema: SerializableSchema): UserDefinedFunction

    

    UDF that extract dst vertex label

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

    

    DseGraphFrameBuilder.dseGraph should be used instead of this

18. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

19. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

20. def edgeLabelNameColumn(schema: SerializableSchema): Column

    
    returns

    UDF that extract label name from the edgeLabelId

21. def edgeLabelNameUdf(schema: SerializableSchema): UserDefinedFunction

    

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

    

    Definition Classes

    AnyRef

23. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

24. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

25. def fromGfName(name: String): String

    

26. def fromGfNames(df: DataFrame): DataFrame

    

27. val fromGfNamesRegex: Regex

    

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

    

    Definition Classes

    AnyRef → Any

29. def getSchemaFromServer(graphName: String, connector: CassandraConnector): SerializableSchema

    

30. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

31. def hiveQuote(columns: Seq[String]): Seq[String]

    

32. def hiveQuote(column: String): String

    

33. def hiveQuoteColumn(name: String): Column

    

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

    

35. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

36. def naturalEdgeLabelUdf(direction: Direction, schema: SerializableSchema): UserDefinedFunction

    

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

    

    Definition Classes

    AnyRef

38. final def notify(): Unit

    

    Definition Classes

    AnyRef

39. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

40. def sqlSchema(props: Seq[Property]): StructType

    

    get SQL schema for given properties

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

    

    Definition Classes

    AnyRef

42. def syntheticAdjVertexIdColumn(schema: SerializableSchema): Column

    

    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

    

    UDF that extract dst vertex label

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

    

    udf function for non standard id

45. def syntheticStandardIdUdf: UserDefinedFunction

    

    idf function for standard id

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

    

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

    

    Vertex id has format vertexLabel:base64(idColumns)

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

    
    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]

    

    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

    
    id

    in form "label:encode64(data)"

    schema

    graph schema

    returns

    ExternalId object

51. def toGfColumn(name: String): Column

    

52. def toGfName(name: String): String

    

53. val toGfNamesRegex: Regex

    

54. def toString(): String

    

    Definition Classes

    AnyRef → Any

55. def vertexNonStandardIdUdf(vertex: Vertex): UserDefinedFunction

    

    restore vertex Id from the GraphFrame Vertex id

56. def vertexStandardIdUdf: UserDefinedFunction

    

    restore vertex Id from the GraphFrame Vertex id

57. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

58. final def wait(arg0: Long, arg1: Int): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

59. final def wait(arg0: Long): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )