-
Notifications
You must be signed in to change notification settings - Fork 1.3k
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.
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
Deprecate PinotHelixResourceManager#getAllTables() in favour of getAllTables(String databaseName) #12782
Deprecate PinotHelixResourceManager#getAllTables() in favour of getAllTables(String databaseName) #12782
Conversation
_helixResourceManager.getDatabaseNames().stream() | ||
.map(_helixResourceManager::getAllTables) | ||
.flatMap(List::stream) | ||
.forEach(tableNameWithType -> { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
looped code is not changed at all.
Codecov ReportAttention: Patch coverage is
Additional details and impacted files@@ Coverage Diff @@
## master #12782 +/- ##
============================================
+ Coverage 61.75% 61.99% +0.24%
+ Complexity 207 198 -9
============================================
Files 2436 2461 +25
Lines 133233 134737 +1504
Branches 20636 20818 +182
============================================
+ Hits 82274 83533 +1259
- Misses 44911 45055 +144
- Partials 6048 6149 +101
Flags with carried forward coverage won't be shown. Click here to find out more. ☔ View full report in Codecov by Sentry. |
if (existSchemaName == null || existSchemaName.equals(rawTableName)) { | ||
// Although the table config is valid, we still need to ensure the schema exists | ||
if (!schemaExists) { | ||
LOGGER.warn("Failed to find schema for table: {}", tableNameWithType); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
minor: change all the log lines to reflect the database name as well along with table name
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Ok, seems like all table names already contain the dbName so this can be ignored.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Yeah that's correct.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
One minor comment, overall LGTM
This is not efficient, and there are other places not handled correctly. Please take a look at #12804 |
Description
PinotHelixResourceManager#getAllTables()
in favour ofPinotHelixResourceManager#getAllTables(String databaseName)
asgetAllTables()
only works fordefault
database.labels
release-notes
release-notes
Deprecating
PinotHelixResourceManager#getAllTables()
in favour ofPinotHelixResourceManager#getAllTables(String databaseName)