We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
getTables()
r.SQLUtils
1 parent cf98a76 commit bedd63bCopy full SHA for bedd63b
sql/core/src/main/scala/org/apache/spark/sql/api/r/SQLUtils.scala
@@ -216,15 +216,6 @@ private[sql] object SQLUtils extends Logging {
216
}
217
218
219
- def getTables(sparkSession: SparkSession, databaseName: String): DataFrame = {
220
- databaseName match {
221
- case n: String if n != null && n.trim.nonEmpty =>
222
- Dataset.ofRows(sparkSession, ShowTablesCommand(Some(n), None))
223
- case _ =>
224
- Dataset.ofRows(sparkSession, ShowTablesCommand(None, None))
225
- }
226
227
-
228
def getTableNames(sparkSession: SparkSession, databaseName: String): Array[String] = {
229
val db = databaseName match {
230
case _ if databaseName != null && databaseName.trim.nonEmpty =>
0 commit comments