File tree 1 file changed +0
-38
lines changed
crates/hdfs-native-object-store/src
1 file changed +0
-38
lines changed Original file line number Diff line number Diff line change @@ -553,44 +553,6 @@ impl MultipartUpload for HdfsMultipartWriter {
553
553
} )
554
554
}
555
555
}
556
- // /// Upload a single part
557
- // async fn put_part(&self, buf: Vec<u8>, part_idx: usize) -> Result<PartId> {
558
- // if part_idx != self.next_part.load(Ordering::SeqCst) {
559
- // return Err(object_store::Error::NotSupported {
560
- // source: "Part received out of order".to_string().into(),
561
- // });
562
- // }
563
-
564
- // self.inner
565
- // .lock()
566
- // .await
567
- // .write(buf.into())
568
- // .await
569
- // .to_object_store_err()?;
570
-
571
- // self.next_part.fetch_add(1, Ordering::SeqCst);
572
-
573
- // Ok(PartId {
574
- // content_id: part_idx.to_string(),
575
- // })
576
- // }
577
-
578
- // /// Complete the upload with the provided parts
579
- // ///
580
- // /// `completed_parts` is in order of part number
581
- // async fn complete(&self, _completed_parts: Vec<PartId>) -> Result<()> {
582
- // self.inner
583
- // .lock()
584
- // .await
585
- // .close()
586
- // .await
587
- // .to_object_store_err()?;
588
- // self.client
589
- // .rename(&self.tmp_filename, &self.final_filename, true)
590
- // .await
591
- // .to_object_store_err()?;
592
- // Ok(())
593
- // }
594
556
}
595
557
596
558
/// ObjectStore paths always remove the leading slash, so add it back
You can’t perform that action at this time.
0 commit comments