danny0405 commented on code in PR #11924:
URL: https://github.com/apache/hudi/pull/11924#discussion_r1881354297
##########
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieAvroDataBlock.java:
##########
@@ -224,6 +249,159 @@ public IndexedRecord next() {
}
}
+ /**
+ * StreamingRecordIterator is an iterator for reading records from a Hoodie
log block in a streaming manner.
+ * It reads data from a given input stream, decodes Avro records, and
supports schema promotion.
+ *
+ * This iterator ensures that the buffer has enough data for each record and
handles buffer management,
+ * including compaction and resizing when necessary.
+ */
Review Comment:
```java
/**
* {@code StreamingRecordIterator} is an iterator for reading records from
a Hoodie log block in streaming manner.
* It decodes the given input stream into Avro records with optional
schema promotion.
*
* <p>This iterator ensures that the buffer has enough data for each
record and handles buffer setup,
* including compaction and resizing when necessary.
*/
```
--
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]
