File tree Expand file tree Collapse file tree 2 files changed +2
-24
lines changed
Expand file tree Collapse file tree 2 files changed +2
-24
lines changed Original file line number Diff line number Diff line change @@ -160,7 +160,8 @@ async fn page_index_filter_one_col() {
160160
161161 // 5.create filter date_string_col == "01/01/09"`;
162162 // Note this test doesn't apply type coercion so the literal must match the actual view type
163- let filter = col ( "date_string_col" ) . eq ( lit ( ScalarValue :: new_utf8view ( "01/01/09" ) ) ) ;
163+ // xudong: use new_utf8, because schema_force_view_types was changed to false now.
164+ let filter = col ( "date_string_col" ) . eq ( lit ( ScalarValue :: new_utf8 ( "01/01/09" ) ) ) ;
164165 let parquet_exec = get_parquet_exec ( & state, filter) . await ;
165166 let mut results = parquet_exec. execute ( 0 , task_ctx. clone ( ) ) . unwrap ( ) ;
166167 let batch = results. next ( ) . await . unwrap ( ) . unwrap ( ) ;
Original file line number Diff line number Diff line change 9797//! assert_eq!(format!("{:?}", plan), format!("{:?}", logical_round_trip));
9898//! # Ok(())
9999//! # }
100- //! ```
101- //! # Example: Serializing [`ExecutionPlan`]s
102- //!
103- //! ```
104- //! # use datafusion::prelude::*;
105- //! # use datafusion_common::Result;
106- //! # use datafusion_proto::bytes::{physical_plan_from_bytes,physical_plan_to_bytes};
107- //! # #[tokio::main]
108- //! # async fn main() -> Result<()>{
109- //! // Create a plan that scans table 't'
110- //! let ctx = SessionContext::new();
111- //! ctx.register_csv("t1", "tests/testdata/test.csv", CsvReadOptions::default()).await?;
112- //! let physical_plan = ctx.table("t1").await?.create_physical_plan().await?;
113- //!
114- //! // Convert the plan into bytes (for sending over the network, etc.)
115- //! let bytes = physical_plan_to_bytes(physical_plan.clone())?;
116- //!
117- //! // Decode bytes from somewhere (over network, etc.) back to ExecutionPlan
118- //! let physical_round_trip = physical_plan_from_bytes(&bytes, &ctx)?;
119- //! assert_eq!(format!("{:?}", physical_plan), format!("{:?}", physical_round_trip));
120- //! # Ok(())
121- //! # }
122- //! ```
123100pub mod bytes;
124101pub mod common;
125102pub mod generated;
You can’t perform that action at this time.
0 commit comments