RichDataFrame

Value Members

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

   

   Definition Classes

   Any

2. final def ##(): Int

   

   Definition Classes

   Any

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

   

   Definition Classes

   Any

4. final def asInstanceOf[T0]: T0

   

   Definition Classes

   Any

5. def cacheAndForce(tableName: Option[String] = None): Long

   

   Caches and forces the computation of the DF

   Caches and forces the computation of the DF

   returns

   row count of the DF

6. def cypherTypeForColumn(columnName: String): CypherType

   

   Returns the corresponding Cypher type for the given column name in the data frame.

   Returns the corresponding Cypher type for the given column name in the data frame.

   columnName

   column name

   returns

   Cypher type for column

7. val df: DataFrame

   

8. def getClass(): Class[_ <: AnyVal]

   

   Definition Classes

   AnyVal → Any

9. final def isInstanceOf[T0]: Boolean

   

   Definition Classes

   Any

10. def mapColumn(name: String)(f: (Column) ⇒ Column): DataFrame

    

11. def printExecutionTiming(description: String): Unit

    

    Prints timing of Spark computation for DF.

12. def printPhysicalPlan(): Unit

    

    Prints Spark physical plan.

13. def safeAddColumn(name: String, col: Column): DataFrame

    

14. def safeAddColumns(columns: (String, Column)*): DataFrame

    

15. def safeDropColumn(name: String): DataFrame

    

16. def safeDropColumns(names: String*): DataFrame

    

17. def safeJoin(other: DataFrame, joinCols: Seq[(String, String)], joinType: String): DataFrame

    

18. def safeRenameColumn(oldName: String, newName: String): DataFrame

    

19. def safeRenameColumns(renamings: (String, String)*): DataFrame

    

20. def safeReplaceColumn(name: String, newColumn: Column): DataFrame

    

21. def setNonNullable(columnNames: Set[String]): DataFrame

    

22. def setNonNullable(columnName: String): DataFrame

    

23. def setNullability(mapping: Map[String, CypherType]): DataFrame

    

24. def structFieldForColumn(columnName: String): StructField

    

    Returns the struct field for the given column.

    Returns the struct field for the given column.

    columnName

    column name

    returns

    struct field

25. def toString(): String

    

    Definition Classes

    Any

26. def withCypherCompatibleTypes: DataFrame

    

    Normalises the dataframe by lifting numeric fields to Long and similar ops.