@@ -20,18 +20,18 @@ use std::{
2020use async_trait:: async_trait;
2121use chrono:: { DateTime , Utc } ;
2222use futures:: {
23- stream:: { BoxStream , StreamExt } ,
2423 FutureExt ,
24+ stream:: { BoxStream , StreamExt } ,
2525} ;
2626use hdfs_native:: {
27- client :: FileStatus , file :: FileWriter , Client , ClientBuilder , HdfsError , WriteOptions ,
27+ Client , ClientBuilder , HdfsError , WriteOptions , client :: FileStatus , file :: FileWriter ,
2828} ;
29+ use object_store:: { CopyMode , CopyOptions , RenameOptions , RenameTargetMode } ;
2930#[ allow( deprecated) ]
3031use object_store:: {
31- path :: Path , GetOptions , GetResult , GetResultPayload , ListResult , MultipartUpload , ObjectMeta ,
32- ObjectStore , PutMode , PutMultipartOpts , PutOptions , PutPayload , PutResult , Result , UploadPart ,
32+ GetOptions , GetResult , GetResultPayload , ListResult , MultipartUpload , ObjectMeta , ObjectStore ,
33+ PutMode , PutMultipartOpts , PutOptions , PutPayload , PutResult , Result , UploadPart , path :: Path ,
3334} ;
34- use object_store:: { CopyMode , CopyOptions , RenameOptions , RenameTargetMode } ;
3535use tokio:: {
3636 runtime:: Handle ,
3737 sync:: { mpsc, oneshot} ,
0 commit comments