Skip to content

Commit e8cc271

Browse files
committed
fix example
1 parent 46c0161 commit e8cc271

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

datafusion-examples/examples/custom_data_source/adapter_serialization.rs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -234,10 +234,10 @@ impl PhysicalExprAdapterFactory for MetadataAdapterFactory {
234234
&self,
235235
logical_file_schema: SchemaRef,
236236
physical_file_schema: SchemaRef,
237-
) -> Arc<dyn PhysicalExprAdapter> {
237+
) -> Result<Arc<dyn PhysicalExprAdapter>> {
238238
let inner = DefaultPhysicalExprAdapterFactory
239-
.create(logical_file_schema, physical_file_schema);
240-
Arc::new(MetadataAdapter { inner })
239+
.create(logical_file_schema, physical_file_schema)?;
240+
Ok(Arc::new(MetadataAdapter { inner }))
241241
}
242242
}
243243

0 commit comments

Comments
 (0)