Skip to content

[SPARK-27899][SQL] Make HiveMetastoreClient.getTableObjectsByName available in ExternalCatalog/SessionCatalog API #24774

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Closed
LantaoJin wants to merge 10 commits into from
Closed

[SPARK-27899][SQL] Make HiveMetastoreClient.getTableObjectsByName available in ExternalCatalog/SessionCatalog API #24774

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
dbe6065
[SPARK-27899][SQL] Make HiveMetastoreClient.getTableObjectsByName ava…
LantaoJin Jun 3, 2019
b73eadc
add ut
LantaoJin Jun 3, 2019
7b48220
more robust
LantaoJin Jun 3, 2019
bbb5b18
style
LantaoJin Jun 3, 2019
2d82550
remove useless code
LantaoJin Jun 3, 2019
82a30b9
rename
LantaoJin Jun 3, 2019
b621043
add more unit tests
LantaoJin Jun 5, 2019
93c5261
Fix ut
LantaoJin Jun 5, 2019
873644d
address comment
LantaoJin Jun 6, 2019
d233146
address comments
LantaoJin Jun 10, 2019
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
more robust
  • Loading branch information
@LantaoJin
LantaoJin committed Jun 6, 2019
commit 7b4822047345dd381d8330afdc8675d263823c6d
14 changes: 11 additions & 3 deletions sql/catalyst/src/main/scala/org/apache/spark/sql/catalyst/catalog/SessionCatalog.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -440,10 +440,18 @@ class SessionCatalog(
*/
@throws[NoSuchDatabaseException]
def getTablesByNames(names: Seq[TableIdentifier]): Seq[CatalogTable] = {
val db = formatDatabaseName(names(0).database.getOrElse(getCurrentDatabase))
val tables = names.map(name => formatTableName(name.table))
val db = if (names.nonEmpty) {
formatDatabaseName(names.head.database.getOrElse(getCurrentDatabase))
} else {
getCurrentDatabase
}
requireDbExists(db)
externalCatalog.getTablesByNames(db, tables)
if (names.nonEmpty) {
val tables = names.map(name => formatTableName(name.table))
externalCatalog.getTablesByNames(db, tables)
} else {
getAllTables(db)
}
}

/**
Expand Down