ClassicDseGraphFrame

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

   

   add: ~adjacent_vertex_id ~~adjacent_label_id

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

   

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

   

7. def adjVertexLabelUdf(schema: SerializableSchema): UserDefinedFunction

   

   UDF that extract dst vertex label

8. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

9. def clone(): AnyRef

   

   Attributes

   protected[java.lang]

   Definition Classes

   AnyRef

   Annotations

   @throws( ... )

10. lazy val edgeIdColumnNames: Seq[String]

    

11. def edgeLabelNameColumn(schema: SerializableSchema): Column

    
    returns

    UDF that extract label name from the edgeLabelId

12. def edgeLabelNameUdf(schema: SerializableSchema): UserDefinedFunction

    

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

    

    Definition Classes

    AnyRef

14. def equals(arg0: Any): Boolean

    

    Definition Classes

    AnyRef → Any

15. def finalize(): Unit

    

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

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

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

    

    Definition Classes

    AnyRef → Any

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

    

18. def hashCode(): Int

    

    Definition Classes

    AnyRef → Any

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

    

20. final def isInstanceOf[T0]: Boolean

    

    Definition Classes

    Any

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

    

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

    

    Definition Classes

    AnyRef

23. final def notify(): Unit

    

    Definition Classes

    AnyRef

24. final def notifyAll(): Unit

    

    Definition Classes

    AnyRef

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

    

    get SQL schema for given properties

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

    

    Definition Classes

    AnyRef

27. 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)

28. def syntheticAdjVertexLabelUdf(schema: SerializableSchema): UserDefinedFunction

    

    UDF that extract dst vertex label

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

    

    udf function for non standard id

30. def syntheticStandardIdUdf: UserDefinedFunction

    

    idf function for standard id

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

    

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

    

    Vertex id has format vertexLabel:base64(idColumns)

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

    
    id

    in form "label:encode64(data)"

    vertex

    with column mapping

34. 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}

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

    
    id

    String of vertex ID in the form "label:encode64(data)"

    schema

    Graph schema

    returns

    External ID object

36. def toString(): String

    

    Definition Classes

    AnyRef → Any

37. def vertexNonStandardIdUdf(vertex: Vertex): UserDefinedFunction

    

    restore vertex Id from the GraphFrame Vertex id

38. def vertexStandardIdUdf: UserDefinedFunction

    

    restore vertex Id from the GraphFrame Vertex id

39. final def wait(): Unit

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

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

    

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )