aboutsummaryrefslogtreecommitdiff
path: root/sql/core/src/main/scala/org/apache/spark/sql/catalog/Catalog.scala
diff options
context:
space:
mode:
Diffstat (limited to 'sql/core/src/main/scala/org/apache/spark/sql/catalog/Catalog.scala')
-rw-r--r--sql/core/src/main/scala/org/apache/spark/sql/catalog/Catalog.scala31
1 files changed, 16 insertions, 15 deletions
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/catalog/Catalog.scala b/sql/core/src/main/scala/org/apache/spark/sql/catalog/Catalog.scala
index b439022d22..7f2762c7da 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/catalog/Catalog.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/catalog/Catalog.scala
@@ -102,50 +102,51 @@ abstract class Catalog {
def listColumns(dbName: String, tableName: String): Dataset[Column]
/**
- * Find the database with the specified name. This throws an AnalysisException when the database
+ * Get the database with the specified name. This throws an AnalysisException when the database
* cannot be found.
*
* @since 2.1.0
*/
@throws[AnalysisException]("database does not exist")
- def findDatabase(dbName: String): Database
+ def getDatabase(dbName: String): Database
/**
- * Find the table with the specified name. This table can be a temporary table or a table in the
- * current database. This throws an AnalysisException when the table cannot be found.
+ * Get the table or view with the specified name. This table can be a temporary view or a
+ * table/view in the current database. This throws an AnalysisException when no Table
+ * can be found.
*
* @since 2.1.0
*/
@throws[AnalysisException]("table does not exist")
- def findTable(tableName: String): Table
+ def getTable(tableName: String): Table
/**
- * Find the table with the specified name in the specified database. This throws an
- * AnalysisException when the table cannot be found.
+ * Get the table or view with the specified name in the specified database. This throws an
+ * AnalysisException when no Table can be found.
*
* @since 2.1.0
*/
@throws[AnalysisException]("database or table does not exist")
- def findTable(dbName: String, tableName: String): Table
+ def getTable(dbName: String, tableName: String): Table
/**
- * Find the function with the specified name. This function can be a temporary function or a
+ * Get the function with the specified name. This function can be a temporary function or a
* function in the current database. This throws an AnalysisException when the function cannot
* be found.
*
* @since 2.1.0
*/
@throws[AnalysisException]("function does not exist")
- def findFunction(functionName: String): Function
+ def getFunction(functionName: String): Function
/**
- * Find the function with the specified name. This throws an AnalysisException when the function
+ * Get the function with the specified name. This throws an AnalysisException when the function
* cannot be found.
*
* @since 2.1.0
*/
@throws[AnalysisException]("database or function does not exist")
- def findFunction(dbName: String, functionName: String): Function
+ def getFunction(dbName: String, functionName: String): Function
/**
* Check if the database with the specified name exists.
@@ -155,15 +156,15 @@ abstract class Catalog {
def databaseExists(dbName: String): Boolean
/**
- * Check if the table with the specified name exists. This can either be a temporary table or a
- * table in the current database.
+ * Check if the table or view with the specified name exists. This can either be a temporary
+ * view or a table/view in the current database.
*
* @since 2.1.0
*/
def tableExists(tableName: String): Boolean
/**
- * Check if the table with the specified name exists in the specified database.
+ * Check if the table or view with the specified name exists in the specified database.
*
* @since 2.1.0
*/