From fcd631ea998df60428d7b62bdc3ad332d0f454b7 Mon Sep 17 00:00:00 2001 From: SatvikPatil <54502802+fivetran-satvikpatil@users.noreply.github.com> Date: Fri, 31 Jan 2025 16:48:17 +0530 Subject: [PATCH] feature(V2): V2 proto changes to support history mode (#86) destination proto change Co-authored-by: Satvik Patil --- v2_examples/destination_sdk_v2.proto | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/v2_examples/destination_sdk_v2.proto b/v2_examples/destination_sdk_v2.proto index e14393b..e87848a 100644 --- a/v2_examples/destination_sdk_v2.proto +++ b/v2_examples/destination_sdk_v2.proto @@ -17,6 +17,7 @@ service DestinationConnector { rpc AlterTable(AlterTableRequest) returns (AlterTableResponse) {} rpc Truncate(TruncateRequest) returns (TruncateResponse) {} rpc WriteBatch (WriteBatchRequest) returns (WriteBatchResponse) {} + rpc WriteHistoryBatch (WriteHistoryBatchRequest) returns (WriteBatchResponse) {} } message CapabilitiesRequest {} @@ -97,6 +98,18 @@ message WriteBatchRequest { repeated string replace_files = 5; repeated string update_files = 6; repeated string delete_files = 7; + FileParams file_params = 8; +} + +message WriteHistoryBatchRequest { + map configuration = 1; + string schema_name = 2; + Table table = 3; + map keys = 4; + repeated string earliest_start_files = 5; + repeated string replace_files = 6; + repeated string update_files = 7; + repeated string delete_files = 8; FileParams file_params = 9; }