A RetroSearch Logo

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

Search Query:

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

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

abstract class SQLContext extends Logging with Serializable



Ordering
  1. Grouped
  2. Alphabetic
  3. By Inheritance
Inherited
  1. SQLContext
  2. Serializable
  3. Logging
  4. AnyRef
  5. Any
Visibility
  1. Public
  2. Protected
Type Members
  1.  implicit class LogStringContext extends AnyRef
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 baseRelationToDataFrame(baseRelation: BaseRelation): Dataset[Row]
  6.  def cacheTable(tableName: String): Unit
  7.  def clearCache(): Unit
  8.  def clone(): AnyRef
  9.  def createDataFrame(data: List[_], beanClass: Class[_]): Dataset[Row]
  10.  def createDataFrame(rdd: JavaRDD[_], beanClass: Class[_]): Dataset[Row]
  11.  def createDataFrame(rdd: RDD[_], beanClass: Class[_]): Dataset[Row]
  12.  def createDataFrame(rows: List[Row], schema: StructType): Dataset[Row]
  13.  def createDataFrame(rowRDD: JavaRDD[Row], schema: StructType): Dataset[Row]
  14.  def createDataFrame(rowRDD: RDD[Row], schema: StructType): Dataset[Row]
  15.  def createDataFrame[A <: Product](data: Seq[A])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): Dataset[Row]
  16.  def createDataFrame[A <: Product](rdd: RDD[A])(implicit arg0: scala.reflect.api.JavaUniverse.TypeTag[A]): Dataset[Row]
  17.  def createDataset[T](data: List[T])(implicit arg0: Encoder[T]): Dataset[T]
  18.  def createDataset[T](data: RDD[T])(implicit arg0: Encoder[T]): Dataset[T]
  19.  def createDataset[T](data: Seq[T])(implicit arg0: Encoder[T]): Dataset[T]
  20.  def dropTempTable(tableName: String): Unit
  21.  def emptyDataFrame: Dataset[Row]
  22.  final def eq(arg0: AnyRef): Boolean
  23.  def equals(arg0: AnyRef): Boolean
  24.  def getAllConfs: Map[String, String]
  25.  final def getClass(): Class[_ <: AnyRef]
  26.  def getConf(key: String, defaultValue: String): String
  27.  def getConf(key: String): String
  28.  def hashCode(): Int
  29.  def initializeLogIfNecessary(isInterpreter: Boolean, silent: Boolean): Boolean
  30.  def initializeLogIfNecessary(isInterpreter: Boolean): Unit
  31.  def isCached(tableName: String): Boolean
  32.  final def isInstanceOf[T0]: Boolean
  33.  def isTraceEnabled(): Boolean
  34.  def log: Logger
  35.  def logDebug(msg: => String, throwable: Throwable): Unit
  36.  def logDebug(entry: LogEntry, throwable: Throwable): Unit
  37.  def logDebug(entry: LogEntry): Unit
  38.  def logDebug(msg: => String): Unit
  39.  def logError(msg: => String, throwable: Throwable): Unit
  40.  def logError(entry: LogEntry, throwable: Throwable): Unit
  41.  def logError(entry: LogEntry): Unit
  42.  def logError(msg: => String): Unit
  43.  def logInfo(msg: => String, throwable: Throwable): Unit
  44.  def logInfo(entry: LogEntry, throwable: Throwable): Unit
  45.  def logInfo(entry: LogEntry): Unit
  46.  def logInfo(msg: => String): Unit
  47.  def logName: String
  48.  def logTrace(msg: => String, throwable: Throwable): Unit
  49.  def logTrace(entry: LogEntry, throwable: Throwable): Unit
  50.  def logTrace(entry: LogEntry): Unit
  51.  def logTrace(msg: => String): Unit
  52.  def logWarning(msg: => String, throwable: Throwable): Unit
  53.  def logWarning(entry: LogEntry, throwable: Throwable): Unit
  54.  def logWarning(entry: LogEntry): Unit
  55.  def logWarning(msg: => String): Unit
  56.  final def ne(arg0: AnyRef): Boolean
  57.  final def notify(): Unit
  58.  final def notifyAll(): Unit
  59.  def range(start: Long, end: Long, step: Long, numPartitions: Int): Dataset[Row]
  60.  def range(start: Long, end: Long, step: Long): Dataset[Row]
  61.  def range(start: Long, end: Long): Dataset[Row]
  62.  def range(end: Long): Dataset[Row]
  63.  def setConf(key: String, value: String): Unit
  64.  def sparkContext: SparkContext
  65.  val sparkSession: SparkSession
  66.  def sql(sqlText: String): Dataset[Row]
  67.  final def synchronized[T0](arg0: => T0): T0
  68.  def table(tableName: String): Dataset[Row]
  69.  def tableNames(databaseName: String): Array[String]
  70.  def tableNames(): Array[String]
  71.  def tables(databaseName: String): Dataset[Row]
  72.  def tables(): Dataset[Row]
  73.  def toString(): String
  74.  def uncacheTable(tableName: String): Unit
  75.  final def wait(arg0: Long, arg1: Int): Unit
  76.  final def wait(arg0: Long): Unit
  77.  final def wait(): Unit
  78.  def withLogContext(context: Map[String, String])(body: => Unit): Unit
Deprecated Value Members
  1.  def applySchema(rdd: JavaRDD[_], beanClass: Class[_]): Dataset[Row]
  2.  def applySchema(rdd: RDD[_], beanClass: Class[_]): Dataset[Row]
  3.  def applySchema(rowRDD: JavaRDD[Row], schema: StructType): Dataset[Row]
  4.  def applySchema(rowRDD: RDD[Row], schema: StructType): Dataset[Row]
  5.  def createExternalTable(tableName: String, source: String, schema: StructType, options: Map[String, String]): Dataset[Row]
  6.  def createExternalTable(tableName: String, source: String, schema: StructType, options: Map[String, String]): Dataset[Row]
  7.  def createExternalTable(tableName: String, source: String, options: Map[String, String]): Dataset[Row]
  8.  def createExternalTable(tableName: String, source: String, options: Map[String, String]): Dataset[Row]
  9.  def createExternalTable(tableName: String, path: String, source: String): Dataset[Row]
  10.  def createExternalTable(tableName: String, path: String): Dataset[Row]
  11.  def finalize(): Unit
  12.  def jdbc(url: String, table: String, theParts: Array[String]): Dataset[Row]
  13.  def jdbc(url: String, table: String, columnName: String, lowerBound: Long, upperBound: Long, numPartitions: Int): Dataset[Row]
  14.  def jdbc(url: String, table: String): Dataset[Row]
  15.  def jsonFile(path: String, samplingRatio: Double): Dataset[Row]
  16.  def jsonFile(path: String, schema: StructType): Dataset[Row]
  17.  def jsonFile(path: String): Dataset[Row]
  18.  def jsonRDD(json: JavaRDD[String], samplingRatio: Double): Dataset[Row]
  19.  def jsonRDD(json: RDD[String], samplingRatio: Double): Dataset[Row]
  20.  def jsonRDD(json: JavaRDD[String], schema: StructType): Dataset[Row]
  21.  def jsonRDD(json: RDD[String], schema: StructType): Dataset[Row]
  22.  def jsonRDD(json: JavaRDD[String]): Dataset[Row]
  23.  def jsonRDD(json: RDD[String]): Dataset[Row]
  24.  def load(source: String, schema: StructType, options: Map[String, String]): Dataset[Row]
  25.  def load(source: String, schema: StructType, options: Map[String, String]): Dataset[Row]
  26.  def load(source: String, options: Map[String, String]): Dataset[Row]
  27.  def load(source: String, options: Map[String, String]): Dataset[Row]
  28.  def load(path: String, source: String): Dataset[Row]
  29.  def load(path: String): Dataset[Row]
  30.  def parquetFile(paths: String*): Dataset[Row]

Inherited from Logging

Inherited from AnyRef

Inherited from Any

Basic Operations

Cached Table Management

Configuration

dataframe

Custom DataFrame Creation

Custom Dataset Creation

Persistent Catalog DDL

Generic Data Sources

Specific Data Sources

Support functions for language integrated queries


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