Fix timestamp_index load code in Java

puzpuzpuz · puzpuzpuz · commit ecf70aedf411 · 2025-10-03T11:17:44.000+03:00
diff --git a/core/rust/qdbr/src/parquet_read/mod.rs b/core/rust/qdbr/src/parquet_read/mod.rs
@@ -23,7 +23,7 @@ where
     pub row_group_count: u32,
     pub row_group_sizes_ptr: *const u32,
     pub row_group_sizes: AcVec<u32>,
-    pub timestamp_index: Option<NonMaxU32>, // None (zero) means no designated timestamp
+    pub timestamp_index: Option<NonMaxU32>, // None (~u32::MAX) means no designated timestamp
     pub columns_ptr: *const ColumnMeta,
     pub columns: AcVec<ColumnMeta>,
     reader: R,
diff --git a/core/src/main/java/io/questdb/griffin/engine/table/parquet/PartitionDecoder.java b/core/src/main/java/io/questdb/griffin/engine/table/parquet/PartitionDecoder.java
@@ -307,7 +307,9 @@ public int getRowGroupSize(int rowGroupIndex) {
         }
 
         public int getTimestampIndex() {
-            return Unsafe.getUnsafe().getInt(ptr + TIMESTAMP_INDEX_OFFSET);
+            // The value is stored as Option<NonMaxU32> on the Rust side,
+            // so we need to apply bitwise not to get the actual value.
+            return ~Unsafe.getUnsafe().getInt(ptr + TIMESTAMP_INDEX_OFFSET);
         }
 
         private void init() {

Original file line number	Diff line number	Diff line change
`@@ -307,7 +307,9 @@ public int getRowGroupSize(int rowGroupIndex) {`
`307`	`307`	`}`
`308`	`308`
`309`	`309`	`public int getTimestampIndex() {`
`310`		`- return Unsafe.getUnsafe().getInt(ptr + TIMESTAMP_INDEX_OFFSET);`
	`310`	`+ // The value is stored as Option<NonMaxU32> on the Rust side,`
	`311`	`+ // so we need to apply bitwise not to get the actual value.`
	`312`	`+ return ~Unsafe.getUnsafe().getInt(ptr + TIMESTAMP_INDEX_OFFSET);`
`311`	`313`	`}`
`312`	`314`
`313`	`315`	`private void init() {`