fix page_index_filter_one_col and remove an example of proto

Author: xudong963

datafusion/core/tests/parquet/page_pruning.rs

@@ -160,7 +160,8 @@ async fn page_index_filter_one_col() {
 
     // 5.create filter date_string_col == "01/01/09"`;
     // Note this test doesn't apply type coercion so the literal must match the actual view type
-    let filter = col("date_string_col").eq(lit(ScalarValue::new_utf8view("01/01/09")));
+    // xudong: use new_utf8, because schema_force_view_types was changed to false now.
+    let filter = col("date_string_col").eq(lit(ScalarValue::new_utf8("01/01/09")));
     let parquet_exec = get_parquet_exec(&state, filter).await;
     let mut results = parquet_exec.execute(0, task_ctx.clone()).unwrap();
     let batch = results.next().await.unwrap().unwrap();

datafusion/proto/src/lib.rs

@@ -97,29 +97,6 @@
 //!  assert_eq!(format!("{:?}", plan), format!("{:?}", logical_round_trip));
 //! # Ok(())
 //! # }
-//! ```
-//! # Example: Serializing [`ExecutionPlan`]s
-//!
-//! ```
-//! # use datafusion::prelude::*;
-//! # use datafusion_common::Result;
-//! # use datafusion_proto::bytes::{physical_plan_from_bytes,physical_plan_to_bytes};
-//! # #[tokio::main]
-//! # async fn main() -> Result<()>{
-//!  // Create a plan that scans table 't'
-//!  let ctx = SessionContext::new();
-//!  ctx.register_csv("t1", "tests/testdata/test.csv", CsvReadOptions::default()).await?;
-//!  let physical_plan = ctx.table("t1").await?.create_physical_plan().await?;
-//!
-//!  // Convert the plan into bytes (for sending over the network, etc.)
-//!  let bytes = physical_plan_to_bytes(physical_plan.clone())?;
-//!
-//!  // Decode bytes from somewhere (over network, etc.) back to ExecutionPlan
-//!  let physical_round_trip = physical_plan_from_bytes(&bytes, &ctx)?;
-//!  assert_eq!(format!("{:?}", physical_plan), format!("{:?}", physical_round_trip));
-//! # Ok(())
-//! # }
-//! ```
 pub mod bytes;
 pub mod common;
 pub mod generated;

datafusion/sqllogictest/test_files/limit.slt

@@ -854,7 +854,7 @@ physical_plan
 02)--SortExec: TopK(fetch=1000), expr=[part_key@1 ASC NULLS LAST], preserve_partitioning=[false]
 03)----ProjectionExec: expr=[1 as foo, part_key@0 as part_key]
 04)------CoalescePartitionsExec: fetch=1
-05)--------DataSourceExec: file_groups={3 groups: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/parquet/test_limit_with_partitions/part-1.parquet:0..265], [WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/parquet/test_limit_with_partitions/part-1.parquet:265..530], [WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/parquet/test_limit_with_partitions/part-1.parquet:530..794]]}, projection=[part_key], limit=1, file_type=parquet
+05)--------DataSourceExec: file_groups={3 groups: [[WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/parquet/test_limit_with_partitions/part-2.parquet:0..265], [WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/parquet/test_limit_with_partitions/part-2.parquet:265..530], [WORKSPACE_ROOT/datafusion/sqllogictest/test_files/scratch/parquet/test_limit_with_partitions/part-2.parquet:530..794]]}, projection=[part_key], limit=1, file_type=parquet
 
 query I
 with selection as (