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. def addAdjVertexIdColumns(df: DataFrame, dstColumn: Column, schema: <error>): DataFrame

    

    add: ~adjacent_vertex_id ~~adjacent_label_id

13. def addEdgeLabelColumns(df: DataFrame, label: Column, direction: Direction, schema: <error>): DataFrame

    

14. def addNaturalVertexIdColumns(df: DataFrame, label: String, schema: <error>, id: Column): DataFrame

    

15. def adjVertexLabelUdf(schema: <error>): UserDefinedFunction

    

    UDF that extract dst vertex label

16. def apply(graphFrame: GraphFrame, dabaseName: String, schema: <error>): DseGraphFrame

    

    DseGraphFrameBuilder.dseGraph should be used instead of this

17. final def asInstanceOf[T0]: T0

    

    Definition Classes

    Any

18. def clone(): AnyRef

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

19. def edgeLabelNameColumn(schema: <error>): <error>

    
    returns

    UDF that extract label name from the edgeLabelId

20. def edgeLabelNameUdf(schema: <error>): UserDefinedFunction

    

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

    

    Definition Classes

    AnyRef

22. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

23. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

24. def fromGfName(name: String): String

    

25. def fromGfNames(df: DataFrame): DataFrame

    

26. val fromGfNamesRegex: Regex

    

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

    

    Definition Classes

    AnyRef → Any

28. def getSchemaFromServer(graphName: String, connector: CassandraConnector): <error>

    

29. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

30. def idSqlSchema(props: Seq[<error>]): StructType

    

31. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

32. def naturalEdgeLabelUdf(direction: Direction, schema: <error>): UserDefinedFunction

    

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

    

    Definition Classes

    AnyRef

34. final def notify(): Unit

    

    Definition Classes

    AnyRef

35. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

36. def sqlSchema(props: Seq[<error>]): StructType

    

    get SQL schema for given properties

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

    

    Definition Classes

    AnyRef

38. def syntheticAdjVertexIdColumn(schema: <error>): <error>

    

    calculate dst column from ADJACENT_VERTEX_ID column.

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

39. def syntheticAdjVertexLabelUdf(schema: <error>): UserDefinedFunction

    

    UDF that extract dst vertex label

40. def syntheticNonStandardIdUdf(idColumnContainer: <error>, rowWriter: RowWriter[Row]): UserDefinedFunction

    

    udf function for non standard id

41. def syntheticStandardIdUdf: <error>

    

    idf function for standard id

42. def syntheticVertexIdColumn(label: String, hasStandardId: Boolean, idSqlColumns: Seq[Column], idColumnContainer: <error>, rowWriter: RowWriter[Row]): Column

    

43. def syntheticVertexIdColumn(label: String, schema: <error>, idSqlColumns: Seq[Column]): Column

    

    Vertex id has format vertexLabel:base64(idColumns)

44. def toArrayVertexId(id: String, vertex: <error>): Array[AnyRef]

    
    id

    in form "label:encode64(data)"

    vertex

    with column mapping

45. def toExternalEdgeId(label: String, srcId: String, dstId: String, uuid: UUID, schema: <error>): 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}

46. def toExternalVertexId(id: String, schema: <error>): <error>

    
    id

    in form "label:encode64(data)"

    schema

    graph schema

    returns

    ExternalId object

47. def toGfName(name: String): String

    

48. val toGfNamesRegex: Regex

    

49. def toString(): String

    

    Definition Classes

    AnyRef → Any

50. def vertexNonStandardIdUdf(vertex: <error>): <error>

    

    restore vertex Id from the GraphFrame Vertex id

51. def vertexStandardIdUdf: <error>

    

    restore vertex Id from the GraphFrame Vertex id

52. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )