Spark 4.1.1 ScalaDoc - org.apache.spark.sql.catalog.Catalog

abstract class Catalog extends AnyRef

Ordering

  1. Alphabetic
  2. By Inheritance

Inherited

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

Visibility

  1. Public
  2. Protected

Instance Constructors

  1. new Catalog()

Abstract Value Members

  1. abstract def cacheTable(tableName: String, storageLevel: StorageLevel): Unit
  2. abstract def cacheTable(tableName: String): Unit
  3. abstract def clearCache(): Unit
  4. abstract def createTable(tableName: String, source: String, schema: StructType, description: String, options: Map[String, String]): DataFrame
  5. abstract def createTable(tableName: String, source: String, schema: StructType, options: Map[String, String]): DataFrame
  6. abstract def createTable(tableName: String, source: String, description: String, options: Map[String, String]): DataFrame
  7. abstract def createTable(tableName: String, source: String, options: Map[String, String]): DataFrame
  8. abstract def createTable(tableName: String, path: String, source: String): DataFrame
  9. abstract def createTable(tableName: String, path: String): DataFrame
  10. abstract def currentCatalog(): String
  11. abstract def currentDatabase: String
  12. abstract def databaseExists(dbName: String): Boolean
  13. abstract def dropGlobalTempView(viewName: String): Boolean
  14. abstract def dropTempView(viewName: String): Boolean
  15. abstract def functionExists(functionName: String): Boolean
  16. abstract def getDatabase(dbName: String): Database
  17. abstract def getFunction(functionName: String): Function
  18. abstract def getTable(tableName: String): Table
  19. abstract def isCached(tableName: String): Boolean
  20. abstract def listCatalogs(pattern: String): Dataset[CatalogMetadata]
  21. abstract def listCatalogs(): Dataset[CatalogMetadata]
  22. abstract def listColumns(tableName: String): Dataset[Column]
  23. abstract def listDatabases(pattern: String): Dataset[Database]
  24. abstract def listDatabases(): Dataset[Database]
  25. abstract def listFunctions(dbName: String, pattern: String): Dataset[Function]
  26. abstract def listFunctions(dbName: String): Dataset[Function]
  27. abstract def listFunctions(): Dataset[Function]
  28. abstract def listTables(dbName: String, pattern: String): Dataset[Table]
  29. abstract def listTables(dbName: String): Dataset[Table]
  30. abstract def listTables(): Dataset[Table]
  31. abstract def recoverPartitions(tableName: String): Unit
  32. abstract def refreshByPath(path: String): Unit
  33. abstract def refreshTable(tableName: String): Unit
  34. abstract def setCurrentCatalog(catalogName: String): Unit
  35. abstract def setCurrentDatabase(dbName: String): Unit
  36. abstract def tableExists(tableName: String): Boolean
  37. abstract def uncacheTable(tableName: String): Unit
  38. abstract def functionExists(dbName: String, functionName: String): Boolean
  39. abstract def getFunction(dbName: String, functionName: String): Function
  40. abstract def getTable(dbName: String, tableName: String): Table
  41. abstract def listColumns(dbName: String, tableName: String): Dataset[Column]
  42. abstract def tableExists(dbName: String, tableName: String): Boolean

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 createTable(tableName: String, source: String, schema: StructType, description: String, options: Map[String, String]): DataFrame
  7. def createTable(tableName: String, source: String, schema: StructType, options: Map[String, String]): DataFrame
  8. def createTable(tableName: String, source: String, description: String, options: Map[String, String]): DataFrame
  9. def createTable(tableName: String, source: String, options: Map[String, String]): DataFrame
  10. final def eq(arg0: AnyRef): Boolean
  11. def equals(arg0: AnyRef): Boolean
  12. final def getClass(): Class[_ <: AnyRef]
  13. def hashCode(): Int
  14. final def isInstanceOf[T0]: Boolean
  15. final def ne(arg0: AnyRef): Boolean
  16. final def notify(): Unit
  17. final def notifyAll(): Unit
  18. final def synchronized[T0](arg0: => T0): T0
  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

Deprecated Value Members

  1. def createExternalTable(tableName: String, source: String, schema: StructType, options: Map[String, String]): DataFrame
  2. def createExternalTable(tableName: String, source: String, schema: StructType, options: Map[String, String]): DataFrame
  3. def createExternalTable(tableName: String, source: String, options: Map[String, String]): DataFrame
  4. def createExternalTable(tableName: String, source: String, options: Map[String, String]): DataFrame
  5. def createExternalTable(tableName: String, path: String, source: String): DataFrame
  6. def createExternalTable(tableName: String, path: String): DataFrame
  7. def finalize(): Unit

Inherited from AnyRef

Inherited from Any

Ungrouped