File tree Expand file tree Collapse file tree 1 file changed +9
-5
lines changed
crates/integrations/datafusion/src/physical_plan Expand file tree Collapse file tree 1 file changed +9
-5
lines changed Original file line number Diff line number Diff line change @@ -207,17 +207,21 @@ impl ExecutionPlan for IcebergWriteExec {
207
207
let data_file = builder. partition_spec_id ( spec_id) . build ( ) . map_err ( |e| {
208
208
DataFusionError :: Execution ( format ! ( "Failed to build data file: {}" , e) )
209
209
} ) ?;
210
-
210
+
211
211
// Convert to DataFileSerde
212
- let serde = DataFileSerde :: try_from ( data_file, & partition_type, is_version_1) . map_err ( |e| {
213
- DataFusionError :: Execution ( format ! ( "Failed to convert to DataFileSerde: {}" , e) )
212
+ let serde = DataFileSerde :: try_from ( data_file, & partition_type, is_version_1)
213
+ . map_err ( |e| {
214
+ DataFusionError :: Execution ( format ! (
215
+ "Failed to convert to DataFileSerde: {}" ,
216
+ e
217
+ ) )
214
218
} ) ?;
215
-
219
+
216
220
// Serialize to JSON
217
221
let json = serde_json:: to_string ( & serde) . map_err ( |e| {
218
222
DataFusionError :: Execution ( format ! ( "Failed to serialize to JSON: {}" , e) )
219
223
} ) ?;
220
-
224
+
221
225
println ! ( "Serialized data file: {}" , json) ; // todo remove log
222
226
Ok ( json)
223
227
} )
You can’t perform that action at this time.
0 commit comments