Skip to content

Commit 8443898

Browse files
committed
Add MERGE_RECORD_TYPE_COLUMN and MergeRecordType for MERGE_UPSERT_DELETE
1 parent 0ad6c2c commit 8443898

1 file changed

Lines changed: 10 additions & 0 deletions

File tree

  • src/datacustomcode/io/writer

src/datacustomcode/io/writer/base.py

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -32,6 +32,16 @@ class WriteMode(str, Enum):
3232
MERGE_UPSERT_DELETE = "merge_upsert_delete"
3333

3434

35+
class MergeRecordType(str, Enum):
36+
"""Annotation values for the _merge_record_type column required by MERGE_UPSERT_DELETE."""
37+
38+
UPSERT = "UPSERT"
39+
DELETE = "DELETE"
40+
41+
42+
MERGE_RECORD_TYPE_COLUMN = "_merge_record_type"
43+
44+
3545
class BaseDataCloudWriter(BaseDataAccessLayer):
3646
"""Base class for Data Cloud writers."""
3747

0 commit comments

Comments
 (0)