Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://spark.apache.org/docs/latest/api/scala/org/apache/spark/sql/SparkSession.html below:

Spark 4.0.0 ScalaDoc - org.apache.spark.sql.SparkSession



1. Alphabetic
2. By Inheritance

1. SparkSession
2. Closeable
3. AutoCloseable
4. Serializable
5. AnyRef
6. Any

1. Public
2. Protected

1.  new SparkSession()

1.  abstract def addArtifact(source: String, target: String): Unit
2.  abstract def addArtifact(bytes: Array[Byte], target: String): Unit
3.  abstract def addArtifact(uri: URI): Unit
4.  abstract def addArtifact(path: String): Unit
5.  abstract def addArtifacts(uri: URI*): Unit
6.  abstract def addTag(tag: String): Unit
7.  abstract def baseRelationToDataFrame(baseRelation: BaseRelation): DataFrame
8.  abstract def catalog: Catalog
9.  abstract def clearTags(): Unit
10.  abstract def close(): Unit
11.  abstract def conf: RuntimeConfig
12.  abstract def createDataFrame(rdd: JavaRDD[_], beanClass: Class[_]): DataFrame
13.  abstract def createDataFrame(rdd: RDD[_], beanClass: Class[_]): DataFrame
14.  abstract def createDataFrame(rowRDD: JavaRDD[Row], schema: StructType): DataFrame
15.  abstract def createDataFrame(rowRDD: RDD[Row], schema: StructType): DataFrame
16.  abstract def createDataFrame[A <: Product](rdd: RDD[A])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): DataFrame
17.  abstract def createDataFrame(data: List[_], beanClass: Class[_]): DataFrame
18.  abstract def createDataFrame(rows: List[Row], schema: StructType): DataFrame
19.  abstract def createDataFrame[A <: Product](data: Seq[A])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): DataFrame
20.  abstract def createDataset[T](data: RDD[T])(implicit arg0: Encoder[T]): Dataset[T]
21.  abstract def createDataset[T](data: List[T])(implicit arg0: Encoder[T]): Dataset[T]
22.  abstract def createDataset[T](data: Seq[T])(implicit arg0: Encoder[T]): Dataset[T]
23.  abstract def emptyDataFrame: DataFrame
24.  abstract def emptyDataset[T](implicit arg0: Encoder[T]): Dataset[T]
25.  abstract def executeCommand(runner: String, command: String, options: Map[String, String]): DataFrame
26.  abstract def experimental: ExperimentalMethods
27.  abstract def getTags(): Set[String]
28.  abstract val implicits: SQLImplicits
29.  abstract def interruptAll(): Seq[String]
30.  abstract def interruptOperation(operationId: String): Seq[String]
31.  abstract def interruptTag(tag: String): Seq[String]
32.  abstract def listenerManager: ExecutionListenerManager
33.  abstract def newSession(): SparkSession
34.  abstract def range(start: Long, end: Long, step: Long, numPartitions: Int): Dataset[Long]
35.  abstract def range(start: Long, end: Long, step: Long): Dataset[Long]
36.  abstract def range(start: Long, end: Long): Dataset[Long]
37.  abstract def range(end: Long): Dataset[Long]
38.  abstract def read: DataFrameReader
39.  abstract def readStream: DataStreamReader
40.  abstract def removeTag(tag: String): Unit
41.  abstract def sessionState: SessionState
42.  abstract def sharedState: SharedState
43.  abstract def sparkContext: SparkContext
44.  abstract def sql(sqlText: String, args: Map[String, Any]): DataFrame
45.  abstract def sql(sqlText: String, args: Array[_]): DataFrame
46.  abstract def sqlContext: SQLContext
47.  abstract def streams: StreamingQueryManager
48.  abstract def table(tableName: String): DataFrame
49.  abstract def tvf: TableValuedFunction
50.  abstract def udf: UDFRegistration
51.  abstract def version: String

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.  final def eq(arg0: AnyRef): Boolean
7.  def equals(arg0: AnyRef): Boolean
8.  final def getClass(): Class[_ <: AnyRef]
9.  def hashCode(): Int
10.  final def isInstanceOf[T0]: Boolean
11.  final def ne(arg0: AnyRef): Boolean
12.  final def notify(): Unit
13.  final def notifyAll(): Unit
14.  def sql(sqlText: String): DataFrame
15.  def sql(sqlText: String, args: Map[String, Any]): DataFrame
16.  def stop(): Unit
17.  final def synchronized[T0](arg0: => T0): T0
18.  def time[T](f: => T): T
19.  def toString(): String
20.  final def wait(arg0: Long, arg1: Int): Unit
21.  final def wait(arg0: Long): Unit
22.  final def wait(): Unit
23.  def withActive[T](block: => T): T

1.  def finalize(): Unit

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4