File tree 1 file changed +8
-1
lines changed
1 file changed +8
-1
lines changed Original file line number Diff line number Diff line change @@ -65,7 +65,6 @@ pub static QUERY_SESSION: Lazy<SessionContext> =
65
65
pub static QUERY_RUNTIME : Lazy < Runtime > =
66
66
Lazy :: new ( || Runtime :: new ( ) . expect ( "Runtime should be constructible" ) ) ;
67
67
68
-
69
68
/// This function executes a query on the dedicated runtime, ensuring that the query is not isolated to a single thread/CPU
70
69
/// at a time and has access to the entire thread pool, enabling better concurrent processing, and thus quicker results.
71
70
pub async fn execute (
@@ -126,6 +125,14 @@ impl Query {
126
125
. execution
127
126
. use_row_number_estimates_to_optimize_partitioning = true ;
128
127
128
+ //adding this config as it improves query performance as explained here -
129
+ // https://github.com/apache/datafusion/pull/13101
130
+ config
131
+ . options_mut ( )
132
+ . execution
133
+ . parquet
134
+ . schema_force_view_types = true ;
135
+
129
136
let state = SessionStateBuilder :: new ( )
130
137
. with_default_features ( )
131
138
. with_config ( config)
You can’t perform that action at this time.
0 commit comments