MCPcopy Create free account
hub / github.com/apache/paimon-rust / read_with_evolution

Method read_with_evolution

crates/paimon/src/table/table_read.rs:162–177  ·  view source on GitHub ↗

Read with data-evolution support.

(
        &self,
        data_splits: &[DataSplit],
        core_options: &CoreOptions,
    )

Source from the content-addressed store, hash-verified

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> {

Callers 1

to_arrowMethod · 0.80

Calls 9

schema_managerMethod · 0.80
to_vecMethod · 0.80
read_typeMethod · 0.80
blob_as_descriptorMethod · 0.80
idMethod · 0.45
schemaMethod · 0.45
fieldsMethod · 0.45
readMethod · 0.45

Tested by

no test coverage detected