|
17 | 17 |
|
18 | 18 | //! Object store implementation used for testing |
19 | 19 |
|
20 | | -use crate::execution::context::SessionState; |
21 | | -use crate::execution::session_state::SessionStateBuilder; |
22 | | -use crate::prelude::SessionContext; |
23 | | -use futures::stream::BoxStream; |
24 | | -use futures::FutureExt; |
25 | | -use object_store::{ |
26 | | - memory::InMemory, path::Path, Error, GetOptions, GetResult, ListResult, |
27 | | - MultipartUpload, ObjectMeta, ObjectStore, PutMultipartOptions, PutOptions, |
28 | | - PutPayload, PutResult, |
| 20 | +use crate::{ |
| 21 | + execution::{context::SessionState, session_state::SessionStateBuilder}, |
| 22 | + object_store::{ |
| 23 | + memory::InMemory, path::Path, Error, GetOptions, GetResult, ListResult, |
| 24 | + MultipartUpload, ObjectMeta, ObjectStore, PutMultipartOptions, PutOptions, |
| 25 | + PutPayload, PutResult, |
| 26 | + }, |
| 27 | + prelude::SessionContext, |
| 28 | +}; |
| 29 | +use futures::{stream::BoxStream, FutureExt}; |
| 30 | +use std::{ |
| 31 | + fmt::{Debug, Display, Formatter}, |
| 32 | + sync::Arc, |
29 | 33 | }; |
30 | | -use std::fmt::{Debug, Display, Formatter}; |
31 | | -use std::sync::Arc; |
32 | 34 | use tokio::{ |
33 | 35 | sync::Barrier, |
34 | 36 | time::{timeout, Duration}, |
|
0 commit comments