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

class SparkSession extends Serializable with Closeable with Logging

 

Ordering

1. Alphabetic
2. By Inheritance

Inherited

1. SparkSession

2. Logging

3. Closeable

4. AutoCloseable

5. Serializable

6. Serializable

7. AnyRef

8. Any

9. Hide All

10. 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 baseRelationToDataFrame(baseRelation: BaseRelation): DataFrame
6.  lazy val catalog: Catalog
7.  def clone(): AnyRef
8.  def close(): Unit
9.  lazy val conf: RuntimeConfig
10.  def createDataFrame(data: List[_], beanClass: Class[_]): DataFrame
11.  def createDataFrame(rdd: JavaRDD[_], beanClass: Class[_]): DataFrame
12.  def createDataFrame(rdd: RDD[_], beanClass: Class[_]): DataFrame
13.  def createDataFrame(rows: List[Row], schema: StructType): DataFrame
14.  def createDataFrame(rowRDD: JavaRDD[Row], schema: StructType): DataFrame
15.  def createDataFrame(rowRDD: RDD[Row], schema: StructType): DataFrame
16.  def createDataFrame[A <: Product](data: Seq[A])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): DataFrame
17.  def createDataFrame[A <: Product](rdd: RDD[A])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): DataFrame
18.  def createDataset[T](data: List[T])(implicit arg0: Encoder[T]): Dataset[T]
19.  def createDataset[T](data: RDD[T])(implicit arg0: Encoder[T]): Dataset[T]
20.  def createDataset[T](data: Seq[T])(implicit arg0: Encoder[T]): Dataset[T]
21.  lazy val emptyDataFrame: DataFrame
22.  def emptyDataset[T](implicit arg0: Encoder[T]): Dataset[T]
23.  final def eq(arg0: AnyRef): Boolean
24.  def equals(arg0: Any): Boolean
25.  def executeCommand(runner: String, command: String, options: Map[String, String]): DataFrame
26.  def experimental: ExperimentalMethods
27.  def finalize(): Unit
28.  final def getClass(): Class[_]
29.  def hashCode(): Int
30.  def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
31.  def initializeLogIfNecessary(isInterpreter: Boolean): Unit
32.  final def isInstanceOf[T0]: Boolean
33.  def isTraceEnabled(): Boolean
34.  def listenerManager: ExecutionListenerManager
35.  def log: Logger
36.  def logDebug(msg: ⇒ String, throwable: Throwable): Unit
37.  def logDebug(msg: ⇒ String): Unit
38.  def logError(msg: ⇒ String, throwable: Throwable): Unit
39.  def logError(msg: ⇒ String): Unit
40.  def logInfo(msg: ⇒ String, throwable: Throwable): Unit
41.  def logInfo(msg: ⇒ String): Unit
42.  def logName: String
43.  def logTrace(msg: ⇒ String, throwable: Throwable): Unit
44.  def logTrace(msg: ⇒ String): Unit
45.  def logWarning(msg: ⇒ String, throwable: Throwable): Unit
46.  def logWarning(msg: ⇒ String): Unit
47.  final def ne(arg0: AnyRef): Boolean
48.  def newSession(): SparkSession
49.  final def notify(): Unit
50.  final def notifyAll(): Unit
51.  def parseDataType(dataTypeString: String): DataType
52.  def range(start: Long, end: Long, step: Long, numPartitions: Int): Dataset[Long]
53.  def range(start: Long, end: Long, step: Long): Dataset[Long]
54.  def range(start: Long, end: Long): Dataset[Long]
55.  def range(end: Long): Dataset[Long]
56.  def read: DataFrameReader
57.  def readStream: DataStreamReader
58.  lazy val sessionState: SessionState
59.  lazy val sharedState: SharedState
60.  val sparkContext: SparkContext
61.  def sql(sqlText: String): DataFrame
62.  def sql(sqlText: String, args: Map[String, Any]): DataFrame
63.  def sql(sqlText: String, args: Map[String, Any]): DataFrame
64.  def sql(sqlText: String, args: Array[_]): DataFrame
65.  val sqlContext: SQLContext
66.  def stop(): Unit
67.  def streams: StreamingQueryManager
68.  final def synchronized[T0](arg0: ⇒ T0): T0
69.  def table(tableName: String): DataFrame
70.  def time[T](f: ⇒ T): T
71.  def toString(): String
72.  def udf: UDFRegistration
73.  def udtf: UDTFRegistration
74.  def version: String
75.  final def wait(): Unit
76.  final def wait(arg0: Long, arg1: Int): Unit
77.  final def wait(arg0: Long): Unit
78.  object implicits extends SQLImplicits with Serializable

Inherited from Logging

Inherited from Closeable

Inherited from AutoCloseable

Inherited from Serializable

Inherited from Serializable

Inherited from AnyRef

Inherited from Any

Ungrouped