File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -116,12 +116,15 @@ impl RunOpt {
116116 None => queries. min_query_id ( ) ..=queries. max_query_id ( ) ,
117117 } ;
118118
119+ // configure parquet options
119120 let mut config = self . common . config ( ) ;
120- config
121- . options_mut ( )
122- . execution
123- . parquet
124- . schema_force_view_types = self . common . force_view_types ;
121+ {
122+ let mut parquet_options = & mut config. options_mut ( ) . execution . parquet ;
123+ parquet_options. schema_force_view_types = self . common . force_view_types ;
124+ // The hits_partitioned dataset specifies string columns
125+ // as binary due to how it was written. Force it to strings
126+ parquet_options. binary_as_string = true ;
127+ }
125128
126129 let ctx = SessionContext :: new_with_config ( config) ;
127130 self . register_hits ( & ctx) . await ?;
@@ -149,7 +152,7 @@ impl RunOpt {
149152 Ok ( ( ) )
150153 }
151154
152- /// Registrs the `hits.parquet` as a table named `hits`
155+ /// Registers the `hits.parquet` as a table named `hits`
153156 async fn register_hits ( & self , ctx : & SessionContext ) -> Result < ( ) > {
154157 let options = Default :: default ( ) ;
155158 let path = self . path . as_os_str ( ) . to_str ( ) . unwrap ( ) ;
You can’t perform that action at this time.
0 commit comments