luoyuxia commented on code in PR #2223:
URL: https://github.com/apache/fluss/pull/2223#discussion_r2650088992
##########
fluss-rpc/src/main/proto/FlussApi.proto:
##########
@@ -947,11 +949,53 @@ message PbModifyColumn {
optional int32 column_position_type = 4; // LAST=0,FIRST=1,AFTER=3
}
-
-
message PbDescribeConfig {
required string config_key = 1;
optional string config_value = 2;
required string config_source = 3;
}
+message PbLakeTableSnapshotMetadata {
+ required int64 table_id = 1;
+ required int64 snapshot_id = 2;
+ required string tiered_bucket_offsets_file_path = 3;
+ optional string readable_bucket_offsets_file_path = 4;
+}
+
+message PbLakeTableSnapshotInfo {
+ optional int64 table_id = 1;
+ required int64 snapshot_id = 2;
+ repeated PbLakeTableOffsetForBucket buckets_req = 3;
+ // add table path to reduce get table_path by table id
+ optional PbTablePath table_path = 4;
+}
+
+message PbLakeTableOffsetForBucket {
+ optional int64 partition_id = 1;
+ required int32 bucket_id = 2;
+ // Deprecated: log_start_offset is no longer used. Field number 3 is
reserved for protocol compatibility.
+ // optional int64 log_start_offset = 3;
+ optional int64 log_end_offset = 4;
+ // Deprecated: partition_name is no longer used. Field number 5 is reserved
for protocol compatibility.
+ // optional string partition_name = 5;
+ optional int64 max_timestamp = 6;
+}
+
+message PbPrepareCommitLakeTableRespForTable {
Review Comment:
I was thinking to use array index to distinguish the
`PbPrepareCommitLakeTableRespForTable ` belong to. It's a week contract. I'm
fine with attaching table id which is a stronger contract, and also align with
`CommitLakeTableSnapshotRequest`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
