Skip to content

Commit b18633e

Browse files
committed
[feat] implement pruned_partition_list
1 parent 5f0d09d commit b18633e

File tree

7 files changed

+781
-271
lines changed

7 files changed

+781
-271
lines changed

ballista/rust/core/src/serde/logical_plan/to_proto.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -736,7 +736,7 @@ impl TryInto<protobuf::LogicalPlanNode> for &LogicalPlan {
736736
.file_extension
737737
.clone(),
738738
partitions: listing_table.options().partitions.clone(),
739-
path: listing_table.path().to_owned(),
739+
path: listing_table.table_path().to_owned(),
740740
schema: Some(schema),
741741
projection,
742742
filters,

ballista/rust/core/src/serde/physical_plan/from_proto.rs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -30,7 +30,7 @@ use crate::serde::protobuf::ShuffleReaderPartition;
3030
use crate::serde::scheduler::PartitionLocation;
3131
use crate::serde::{from_proto_binary_op, proto_error, protobuf, str_to_byte};
3232
use crate::{convert_box_required, convert_required, into_required};
33-
use chrono::{DateTime, NaiveDateTime, TimeZone, Utc};
33+
use chrono::{TimeZone, Utc};
3434
use datafusion::arrow::datatypes::{DataType, Schema, SchemaRef};
3535
use datafusion::catalog::catalog::{
3636
CatalogList, CatalogProvider, MemoryCatalogList, MemoryCatalogProvider,

0 commit comments

Comments
 (0)