-
Notifications
You must be signed in to change notification settings - Fork 201
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
Initial spark 3.5 catalog #1333
Initial spark 3.5 catalog #1333
Conversation
/gcbrun |
...-3.5-bigquery-lib/src/main/java/com/google/cloud/spark/bigquery/v2/BigQueryTableCatalog.java
Outdated
Show resolved
Hide resolved
...-3.5-bigquery-lib/src/main/java/com/google/cloud/spark/bigquery/v2/BigQueryTableCatalog.java
Outdated
Show resolved
Hide resolved
...-3.5-bigquery-lib/src/main/java/com/google/cloud/spark/bigquery/v2/BigQueryTableCatalog.java
Outdated
Show resolved
Hide resolved
} | ||
|
||
@Override | ||
public Table alterTable(Identifier identifier, TableChange... tableChanges) |
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.
Is this something that we want to support later?
...query-lib/src/main/java/com/google/cloud/spark/bigquery/v2/Spark34BigQueryTableProvider.java
Show resolved
Hide resolved
...-3.5-bigquery-lib/src/main/java/com/google/cloud/spark/bigquery/v2/BigQueryTableCatalog.java
Outdated
Show resolved
Hide resolved
The write integration tests are failing in the build. PTAL. |
@Override | ||
public Table loadTable(Identifier identifier) throws NoSuchTableException { | ||
logger.debug("loading table [{}])", format(identifier)); | ||
return identifierToTableMapping.computeIfAbsent( |
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.
This is a cache with no expiry. Seems problematic.
Is this safe to use across scans?
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.
Thanks, replaced with a cache. It should be safe, unless the table is deleted and re-created with a different schema in the same process
/gcbrun |
1 similar comment
/gcbrun |
Can you please update the Changes.md as well? |
f0d67cd
to
82de568
Compare
2cea89c
into
GoogleCloudDataproc:master
No description provided.