File tree Expand file tree Collapse file tree
datafusion/datasource/src/file_stream Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -79,24 +79,19 @@ impl<'a> FileStreamBuilder<'a> {
7979 } = self ;
8080
8181 let Some ( partition) = partition else {
82- return internal_err ! ( "FileStreamBuilder missing required field: partition" ) ;
82+ return internal_err ! ( "FileStreamBuilder missing required partition" ) ;
8383 } ;
8484 let Some ( file_opener) = file_opener else {
85- return internal_err ! (
86- "FileStreamBuilder missing required field: file_opener"
87- ) ;
85+ return internal_err ! ( "FileStreamBuilder missing required file_opener" ) ;
8886 } ;
8987 let Some ( metrics) = metrics else {
90- return internal_err ! ( "FileStreamBuilder missing required field: metrics" ) ;
88+ return internal_err ! ( "FileStreamBuilder missing required metrics" ) ;
9189 } ;
9290 let projected_schema = config. projected_schema ( ) ?;
93- let file_group = match config. file_groups . get ( partition) . cloned ( ) {
94- Some ( file_group) => file_group,
95- None => {
96- return internal_err ! (
97- "FileStreamBuilder invalid partition index: {partition}"
98- ) ;
99- }
91+ let Some ( file_group) = config. file_groups . get ( partition) . cloned ( ) else {
92+ return internal_err ! (
93+ "FileStreamBuilder invalid partition index: {partition}"
94+ ) ;
10095 } ;
10196
10297 Ok ( FileStream {
You can’t perform that action at this time.
0 commit comments