fix: revert changes on flatsource

This commit is contained in:
Ning Sun
2026-05-22 00:52:07 +08:00
parent 9ac92e50e8
commit 4e461adfc3

View File

@@ -1163,7 +1163,7 @@ impl FlatSource {
}
}
pub fn schema(&self) -> &SchemaRef {
pub(crate) fn schema(&self) -> &SchemaRef {
&self.schema
}
@@ -1171,6 +1171,7 @@ impl FlatSource {
self.inner.next_batch().await
}
#[cfg(test)]
pub(crate) fn take_iter(self) -> BoxedRecordBatchIterator {
match self.inner {
FlatSourceInner::Iter(iter) => iter,