Skip to content

Commit

Permalink
fix styles.
Browse files Browse the repository at this point in the history
  • Loading branch information
Rachelint committed Jun 24, 2024
1 parent 9990f5f commit d4391e3
Showing 1 changed file with 6 additions and 6 deletions.
12 changes: 6 additions & 6 deletions integrations/object_store/src/store.rs
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@
// specific language governing permissions and limitations
// under the License.

use std::fmt::{self, Debug, Display, Formatter};
use std::fmt::{Debug, Display, Formatter};
use std::future::IntoFuture;
use std::ops::Range;
use std::sync::Arc;
Expand Down Expand Up @@ -174,7 +174,7 @@ impl ObjectStore for OpendalStore {
.into_send()
.await
.map_err(|err| format_object_store_error(err, location.as_ref()))?;
let upload = OpendalUpload::new(writer, location.clone());
let upload = OpendalMultipartUpload::new(writer, location.clone());

Ok(Box::new(upload))
}
Expand Down Expand Up @@ -418,7 +418,7 @@ impl ObjectStore for OpendalStore {
}

/// `MultipartUpload`'s impl based on `Writer` in opendal
struct OpendalUpload {
struct OpendalMultipartUpload {
// Refer to the fs impl in `object_store`:
// https://github.com/apache/arrow-rs/blob/a35214f92ad7c3bce19875bb091cb776447aa49e/object_store/src/local.rs#L715
// IO exists during locking, so use tokio::sync::Mutex here
Expand All @@ -427,7 +427,7 @@ struct OpendalUpload {
location: Path,
}

impl OpendalUpload {
impl OpendalMultipartUpload {
fn new(writer: Writer, location: Path) -> Self {
Self {
writer: Arc::new(Mutex::new(writer)),
Expand All @@ -437,7 +437,7 @@ impl OpendalUpload {
}

#[async_trait]
impl MultipartUpload for OpendalUpload {
impl MultipartUpload for OpendalMultipartUpload {
fn put_part(&mut self, data: PutPayload) -> UploadPart {
let writer = self.writer.clone();
let location = self.location.clone();
Expand Down Expand Up @@ -477,7 +477,7 @@ impl MultipartUpload for OpendalUpload {
}
}

impl fmt::Debug for OpendalUpload {
impl Debug for OpendalMultipartUpload {
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
f.debug_struct("OpendalMultipartUpload")
.field("location", &self.location)
Expand Down

0 comments on commit d4391e3

Please sign in to comment.