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; }