File tree Expand file tree Collapse file tree 1 file changed +1
-2
lines changed
src/operator/src/statement Expand file tree Collapse file tree 1 file changed +1
-2
lines changed Original file line number Diff line number Diff line change @@ -22,7 +22,7 @@ use common_base::readable_size::ReadableSize;
2222use common_datasource:: file_format:: csv:: CsvFormat ;
2323use common_datasource:: file_format:: json:: JsonFormat ;
2424use common_datasource:: file_format:: orc:: { ReaderAdapter , infer_orc_schema, new_orc_stream_reader} ;
25- use common_datasource:: file_format:: { FileFormat , Format } ;
25+ use common_datasource:: file_format:: { FileFormat , Format , file_to_stream } ;
2626use common_datasource:: lister:: { Lister , Source } ;
2727use common_datasource:: object_store:: { FS_SCHEMA , build_backend, parse_url} ;
2828use common_datasource:: util:: find_dir_and_filename;
@@ -33,7 +33,6 @@ use common_telemetry::{debug, tracing};
3333use datafusion:: datasource:: physical_plan:: { CsvSource , FileSource , JsonSource } ;
3434use datafusion:: parquet:: arrow:: ParquetRecordBatchStreamBuilder ;
3535use datafusion:: parquet:: arrow:: arrow_reader:: ArrowReaderMetadata ;
36- use datafusion:: physical_plan:: metrics:: ExecutionPlanMetricsSet ;
3736use datafusion_common:: SchemaExt ;
3837use datafusion_expr:: Expr ;
3938use datatypes:: arrow:: compute:: can_cast_types;
You can’t perform that action at this time.
0 commit comments