Spark 4.1.1 ScalaDoc - org.apache.spark.sql.streaming.DataStreamReader

abstract class DataStreamReader extends AnyRef

Ordering

  1. Alphabetic
  2. By Inheritance

Inherited

  1. DataStreamReader
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All

Visibility

  1. Public
  2. Protected

Instance Constructors

  1. new DataStreamReader()

Abstract Value Members

  1. abstract def assertNoSpecifiedSchema(operation: String): Unit
  2. abstract def format(source: String): DataStreamReader.this.type
  3. abstract def load(path: String): DataFrame
  4. abstract def load(): DataFrame
  5. abstract def option(key: String, value: String): DataStreamReader.this.type
  6. abstract def options(options: Map[String, String]): DataStreamReader.this.type
  7. abstract def schema(schema: StructType): DataStreamReader.this.type
  8. abstract def table(tableName: String): DataFrame

Concrete 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(path: String): DataFrame
  7. final def eq(arg0: AnyRef): Boolean
  8. def equals(arg0: AnyRef): Boolean
  9. final def getClass(): Class[_ <: AnyRef]
  10. def hashCode(): Int
  11. final def isInstanceOf[T0]: Boolean
  12. def json(path: String): DataFrame
  13. final def ne(arg0: AnyRef): Boolean
  14. final def notify(): Unit
  15. final def notifyAll(): Unit
  16. def option(key: String, value: Double): DataStreamReader.this.type
  17. def option(key: String, value: Long): DataStreamReader.this.type
  18. def option(key: String, value: Boolean): DataStreamReader.this.type
  19. def options(options: Map[String, String]): DataStreamReader.this.type
  20. def orc(path: String): DataFrame
  21. def parquet(path: String): DataFrame
  22. def schema(schemaString: String): DataStreamReader.this.type
  23. final def synchronized[T0](arg0: => T0): T0
  24. def text(path: String): DataFrame
  25. def textFile(path: String): Dataset[String]
  26. def toString(): String
  27. def validateJsonSchema(): Unit
  28. def validateXmlSchema(): Unit
  29. final def wait(arg0: Long, arg1: Int): Unit
  30. final def wait(arg0: Long): Unit
  31. final def wait(): Unit
  32. def xml(path: String): DataFrame

Deprecated Value Members

  1. def finalize(): Unit

Inherited from AnyRef

Inherited from Any

Ungrouped