luoyuxia commented on PR #3660:
URL: https://github.com/apache/fluss/pull/3660#issuecomment-5003260003
@wuchong Could you please help review the api changes. Here's a summary:
```
// RPC proto changes
message PbTableOffsets {
required int64 table_id = 1;
repeated PbBucketOffset bucket_offset = 2;
optional TablePath table_path = 3;
// New: opaque table-level tiering state.
optional bytes tiering_state_json = 4;
}
message GetLakeSnapshotResponse {
required int64 table_id = 1;
required int64 snapshot_id = 2;
repeated PbLakeSnapshotForBucket bucket_snapshot = 3;
// New: opaque table-level tiering state.
optional bytes tiering_state_json = 4;
}
// Common persisted model change
class TableBucketOffsets {
long tableId;
Map<TableBucket, Long> offsets;
// New: nullable opaque JSON bytes.
@Nullable byte[] tieringStateJson;
@Nullable
byte[] getTieringStateJson();
}
// Client API change
class LakeSnapshot {
long snapshotId;
Map<TableBucket, Long> tableBucketsOffset;
// New: nullable opaque JSON bytes from RPC.
@Nullable byte[] lakeTieringTableStateJson;
// New public API: lazy parse typed state.
@Nullable
LakeTieringTableState getLakeTieringTableState();
}
// New typed state model
class LakeTieringTableState {
int version;
boolean partitionDoneInitialized;
Map<Long, Long> partitionUpdateTimes;
}
```
--
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]
