-
Notifications
You must be signed in to change notification settings - Fork 7
New issue
Have a question about this project? # for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “#”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? # to your account
Added many new table feature reference tables #45
Conversation
@@ -3,12 +3,13 @@ | |||
from datetime import date, datetime, timedelta | |||
from decimal import Decimal | |||
from pathlib import Path | |||
from typing import Callable, List, Tuple | |||
from typing import Callable, Tuple, List |
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.
A linter make this change?
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.
LGTM.
Might be good to run Black formatting.
|
||
df.repartition(1).write.format('delta').mode('append').save(case.delta_root) | ||
|
||
delta_table.delete(col("letter") == "a") |
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.
Maybe append some more rows here so the tests are a little more reliable?
.execute()) | ||
|
||
df.repartition(1).write.format('delta').mode('append').save(case.delta_root) | ||
spark.sql(f"ALTER TABLE delta.`{delta_path}` ADD CONSTRAINT const1 CHECK (int > 0);") |
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.
Oh my, this syntax.
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 the only way to add a constraint :-) delta-rs though has it part of the builder methods :-D
Description
Added reference tables for check-constraints, deletion vectors, column mapping, generated columns, cdf, timestamp with no zone and icebergcompatv1
How was this patch tested?
I ran it locally and inspected the tables for expected output.
Does this require an update to the documentation?