converts [TableSource] to [LogicalPlan::TableScan] using [LogicalPlan::TableScan] was the best approach to serialize [TableSource] to [LogicalPlan::TableScan]
(
table_name: TableReference,
target: Arc<dyn TableSource>,
extension_codec: &dyn LogicalExtensionCodec,
)
| 367 | /// using [LogicalPlan::TableScan] was the best approach to |
| 368 | /// serialize [TableSource] to [LogicalPlan::TableScan] |
| 369 | fn from_table_source( |
| 370 | table_name: TableReference, |
| 371 | target: Arc<dyn TableSource>, |
| 372 | extension_codec: &dyn LogicalExtensionCodec, |
| 373 | ) -> Result<LogicalPlanNode> { |
| 374 | let projected_schema = target.schema().to_dfschema_ref()?; |
| 375 | let r = LogicalPlan::TableScan(TableScan { |
| 376 | table_name, |
| 377 | source: target, |
| 378 | projection: None, |
| 379 | projected_schema, |
| 380 | filters: vec![], |
| 381 | fetch: None, |
| 382 | }); |
| 383 | |
| 384 | LogicalPlanNode::try_from_logical_plan(&r, extension_codec) |
| 385 | } |
| 386 | |
| 387 | impl AsLogicalPlan for LogicalPlanNode { |
| 388 | fn try_decode(buf: &[u8]) -> Result<Self> |
no test coverage detected
searching dependent graphs…