reverted Utf8View change

Author: nikhilsinhaparseable

src/query/mod.rs

@@ -494,7 +494,7 @@ fn transform(
 ) -> Transformed<LogicalPlan> {
     plan.transform(&|plan| match plan {
         LogicalPlan::TableScan(table) => {
-            let mut new_filters = vec![];
+            let new_filters = vec![];
             if !table_contains_any_time_filters(&table, time_partition) {
                 let mut _start_time_filter: Expr;
                 let mut _end_time_filter: Expr;
@@ -529,8 +529,8 @@ fn transform(
                     }
                 }
 
-                new_filters.push(_start_time_filter);
-                new_filters.push(_end_time_filter);
+                //new_filters.push(_start_time_filter);
+                //new_filters.push(_end_time_filter);
             }
             let new_filter = new_filters.into_iter().reduce(and);
             if let Some(new_filter) = new_filter {

src/query/stream_schema_provider.rs

@@ -435,9 +435,9 @@ impl TableProvider for StandardTableProvider {
             .map_err(|err| DataFusionError::Plan(err.to_string()))?;
         let time_partition = object_store_format.time_partition;
         let mut time_filters = extract_primary_filter(filters, &time_partition);
-        if time_filters.is_empty() {
-            return Err(DataFusionError::Plan("potentially unbounded query on time range. Table scanning requires atleast one time bound".to_string()));
-        }
+        // if time_filters.is_empty() {
+        //     return Err(DataFusionError::Plan("potentially unbounded query on time range. Table scanning requires atleast one time bound".to_string()));
+        // }
 
         if include_now(filters, &time_partition) {
             if let Some(records) =

src/storage/staging.rs

@@ -326,7 +326,8 @@ pub fn parquet_writer_props(
             ColumnPath::new(vec![time_partition_field]),
             Encoding::DELTA_BINARY_PACKED,
         )
-        .set_data_page_size_limit(20 * 1024 * 1024);
+        .set_data_page_size_limit(20 * 1024 * 1024)
+        .set_data_page_row_count_limit(100000);
 
     for (field, index) in custom_partition_fields {
         let field = ColumnPath::new(vec![field]);