rshkv commented on code in PR #863:
URL: https://github.com/apache/iceberg-rust/pull/863#discussion_r1907321249
##########
crates/iceberg/src/metadata_scan.rs:
##########
@@ -128,6 +140,84 @@ impl<'a> SnapshotsTable<'a> {
}
}
+/// Entries table containing the manifest file's entries.
+///
+/// The table has one row for each manifest file entry in the current
snapshot's manifest list file.
+/// For reference, see the Java implementation of [`ManifestEntry`][1].
+///
+/// [1]:
https://github.com/apache/iceberg/blob/apache-iceberg-1.7.1/core/src/main/java/org/apache/iceberg/ManifestEntry.java
+pub struct EntriesTable<'a> {
+ table: &'a Table,
+}
+
+impl<'a> EntriesTable<'a> {
+ /// Get the schema for the manifest entries table.
+ pub fn schema(&self) -> Schema {
+ Schema::new(vec![
+ Field::new("status", DataType::Int32, false),
+ Field::new("snapshot_id", DataType::Int64, true),
+ Field::new("sequence_number", DataType::Int64, true),
+ Field::new("file_sequence_number", DataType::Int64, true),
+ Field::new(
+ "data_file",
+
DataType::Struct(DataFileStructBuilder::fields(self.table.metadata())),
+ false,
+ ),
+ Field::new(
+ "readable_metrics",
+ DataType::Struct(
+
ReadableMetricsStructBuilder::fields(self.table.metadata().current_schema())
+ .expect("Failed to build schema for readable metrics"),
+ ),
+ false,
+ ),
+ ])
+ }
+
+ /// Scan the manifest entries table.
+ pub async fn scan(&self) -> Result<RecordBatch> {
Review Comment:
Rebased this PR on top of #870.
--
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: issues-unsubscr...@iceberg.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
---------------------------------------------------------------------
To unsubscribe, e-mail: issues-unsubscr...@iceberg.apache.org
For additional commands, e-mail: issues-h...@iceberg.apache.org
