-
Notifications
You must be signed in to change notification settings - Fork 3.2k
Allow row column for equality delete #25729
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
base: master
Are you sure you want to change the base?
Conversation
f6058b3
to
f515336
Compare
public void testV2TableWithEqualityDeleteWhenColumnIsRow() | ||
throws Exception | ||
{ | ||
String tableName = "test_v2_equality_delete_column_is_row" + randomNameSuffix(); |
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.
Could you please add more test cases?
@Override | ||
public <T> void set(int i, T t) | ||
{ | ||
throw new UnsupportedOperationException("Testing StructLike does not support setting values."); |
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.
Please update the exception message
@@ -59,4 +82,84 @@ public String toString() | |||
{ | |||
return "TrinoRow" + Arrays.toString(values); | |||
} | |||
|
|||
static Object getObjectValue(ConnectorSession session, Block block, int position, Type type) |
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.
Can we move this logic to IcebergPageSink, maybe an overload with getIcebergValue
, or even maybe we could extract a util
Description
Additional context and related issues
Release notes
( ) This is not user-visible or is docs only, and no release notes are required.
( ) Release notes are required. Please propose a release note for me.
( ) Release notes are required, with the following suggested text: