Read with data-evolution support.
(
&self,
data_splits: &[DataSplit],
core_options: &CoreOptions,
)
| 160 | |
| 161 | /// Read with data-evolution support. |
| 162 | fn read_with_evolution( |
| 163 | &self, |
| 164 | data_splits: &[DataSplit], |
| 165 | core_options: &CoreOptions, |
| 166 | ) -> crate::Result<ArrowRecordBatchStream> { |
| 167 | let reader = DataEvolutionReader::new( |
| 168 | self.table.file_io.clone(), |
| 169 | self.table.schema_manager().clone(), |
| 170 | self.table.schema().id(), |
| 171 | self.table.schema.fields().to_vec(), |
| 172 | self.read_type().to_vec(), |
| 173 | core_options.blob_as_descriptor(), |
| 174 | core_options.blob_descriptor_fields(), |
| 175 | )?; |
| 176 | reader.read(data_splits) |
| 177 | } |
| 178 | |
| 179 | /// Read raw data files without dedup or evolution. |
| 180 | fn read_raw(&self, data_splits: &[DataSplit]) -> crate::Result<ArrowRecordBatchStream> { |
no test coverage detected