Spark 3.5.5 ScalaDoc - org.apache.spark.sql.DataFrameReader (original) (raw)

class DataFrameReader extends Logging

Ordering

  1. Alphabetic
  2. By Inheritance

Inherited

  1. DataFrameReader

  2. Logging

  3. AnyRef

  4. Any

  5. Hide All

  6. Show All

Value Members

  1. final def !=(arg0: Any): Boolean
  2. final def ##(): Int
  3. final def ==(arg0: Any): Boolean
  4. final def asInstanceOf[T0]: T0
  5. def clone(): AnyRef
  6. def csv(paths: String*): DataFrame
  7. def csv(csvDataset: Dataset[String]): DataFrame
  8. def csv(path: String): DataFrame
  9. final def eq(arg0: AnyRef): Boolean
  10. def equals(arg0: Any): Boolean
  11. def finalize(): Unit
  12. def format(source: String): DataFrameReader
  13. final def getClass(): Class[_]
  14. def hashCode(): Int
  15. def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
  16. def initializeLogIfNecessary(isInterpreter: Boolean): Unit
  17. final def isInstanceOf[T0]: Boolean
  18. def isTraceEnabled(): Boolean
  19. def jdbc(url: String, table: String, predicates: Array[String], connectionProperties: Properties): DataFrame
  20. def jdbc(url: String, table: String, columnName: String, lowerBound: Long, upperBound: Long, numPartitions: Int, connectionProperties: Properties): DataFrame
  21. def jdbc(url: String, table: String, properties: Properties): DataFrame
  22. def json(jsonDataset: Dataset[String]): DataFrame
  23. def json(paths: String*): DataFrame
  24. def json(path: String): DataFrame
  25. def load(paths: String*): DataFrame
  26. def load(path: String): DataFrame
  27. def load(): DataFrame
  28. def log: Logger
  29. def logDebug(msg: ⇒ String, throwable: Throwable): Unit
  30. def logDebug(msg: ⇒ String): Unit
  31. def logError(msg: ⇒ String, throwable: Throwable): Unit
  32. def logError(msg: ⇒ String): Unit
  33. def logInfo(msg: ⇒ String, throwable: Throwable): Unit
  34. def logInfo(msg: ⇒ String): Unit
  35. def logName: String
  36. def logTrace(msg: ⇒ String, throwable: Throwable): Unit
  37. def logTrace(msg: ⇒ String): Unit
  38. def logWarning(msg: ⇒ String, throwable: Throwable): Unit
  39. def logWarning(msg: ⇒ String): Unit
  40. final def ne(arg0: AnyRef): Boolean
  41. final def notify(): Unit
  42. final def notifyAll(): Unit
  43. def option(key: String, value: Double): DataFrameReader
  44. def option(key: String, value: Long): DataFrameReader
  45. def option(key: String, value: Boolean): DataFrameReader
  46. def option(key: String, value: String): DataFrameReader
  47. def options(options: Map[String, String]): DataFrameReader
  48. def options(options: Map[String, String]): DataFrameReader
  49. def orc(paths: String*): DataFrame
  50. def orc(path: String): DataFrame
  51. def parquet(paths: String*): DataFrame
  52. def parquet(path: String): DataFrame
  53. def schema(schemaString: String): DataFrameReader
  54. def schema(schema: StructType): DataFrameReader
  55. final def synchronized[T0](arg0: ⇒ T0): T0
  56. def table(tableName: String): DataFrame
  57. def text(paths: String*): DataFrame
  58. def text(path: String): DataFrame
  59. def textFile(paths: String*): Dataset[String]
  60. def textFile(path: String): Dataset[String]
  61. def toString(): String
  62. final def wait(): Unit
  63. final def wait(arg0: Long, arg1: Int): Unit
  64. final def wait(arg0: Long): Unit

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Ungrouped