com.amazonaws.services.s3.transfer.Upload.getProgress()方法的使用及代码示例

x33g5p2x  于2022-02-01 转载在 其他  
字(7.3k)|赞(0)|评价(0)|浏览(104)

本文整理了Java中com.amazonaws.services.s3.transfer.Upload.getProgress()方法的一些代码示例，展示了Upload.getProgress()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Upload.getProgress()方法的具体详情如下：
包路径：com.amazonaws.services.s3.transfer.Upload
类名称：Upload
方法名：getProgress

Upload.getProgress介绍

暂无

代码示例

代码示例来源：origin: awsdocs/aws-doc-sdk-examples

  1. System.out.println("  " + xfer_state);
  2. } else {
  3.   TransferProgress progress = u.getProgress();
  4.   double pct = progress.getPercentTransferred();
  5.   printProgressBar(pct);

代码示例来源：origin: stackoverflow.com

  1. TransferManager transferManager = new TransferManager(provider);
  2. String bucket = "uni-cloud";
  3. File file = new File("//sdcard//Download//cw.pdf");
  4. if(file.exists())
  5. {
  6.   Log.e(TAG,"File found " + file.getName());
  7. }
  8. else {
  9.   Log.e(TAG,"File not found");
  10. }
  12. Upload upload = transferManager.upload(bucket, file.getName(), file);
  13. while (!upload.isDone()){
  14.   //Show a progress bar...
  15.   TransferProgress transferred = upload.getProgress();
  16.   Toast.makeText(this, "Uploading... ", Toast.LENGTH_LONG).show();
  17.   Log.i("Percentage", "" +transferred.getPercentTransferred());
  18. }
  20. Toast.makeText(this, "Uploaded", Toast.LENGTH_LONG).show();

代码示例来源：origin: org.apache.hadoop/hadoop-aws

  1. /**
  2.  * Method to invoke after upload has completed.
  3.  * This can handle race conditions in setup/teardown.
  4.  * @return the number of bytes which were transferred after the notification
  5.  */
  6. public long uploadCompleted() {
  7.  long delta = upload.getProgress().getBytesTransferred() -
  8.    lastBytesTransferred;
  9.  if (delta > 0) {
  10.   LOG.debug("S3A write delta changed after finished: {} bytes", delta);
  11.   fs.incrementPutProgressStatistics(key, delta);
  12.  }
  13.  return delta;
  14. }

代码示例来源：origin: classmethod/gradle-aws-plugin

  1. public void progressChanged(ProgressEvent event) {
  2.     getLogger().info("  {}% uploaded", upload.getProgress().getPercentTransferred());
  3.   }
  4. });

代码示例来源：origin: amazon-archives/aws-ant-tasks

  1. if (printStatusUpdates) {
  2.   while (!upload.isDone()) {
  3.     System.out.print(upload.getProgress()
  4.         .getBytesTransferred()
  5.         + "/"
  6.         + upload.getProgress()
  7.             .getTotalBytesToTransfer()
  8.         + " bytes transferred...\r");
  9.     Thread.sleep(statusUpdatePeriodInMs);
  10.   System.out.print(upload.getProgress()
  11.         .getBytesTransferred()
  12.         + "/"
  13.         + upload.getProgress()
  14.             .getTotalBytesToTransfer()
  15.         + " bytes transferred...\n");

代码示例来源：origin: stackoverflow.com

  1. if(item.getProgress()==100){
  2.   finalHolder.image.setAlpha(1.0f);
  3.   finalHolder.progressUpdate.setVisibility(View.GONE);
  4.   holder.play.setVisibility(View.VISIBLE);
  5. finalHolder.progressUpdate.setProgress(item.getProgress());

代码示例来源：origin: ingenieux/beanstalker

  1. TransferProgress xProgress = upload.getProgress();

代码示例来源：origin: ch.cern.hadoop/hadoop-aws

  1. long delta = upload.getProgress().getBytesTransferred() - listener.getLastBytesTransferred();
  2. if (statistics != null && delta != 0) {
  3.  if (LOG.isDebugEnabled()) {

代码示例来源：origin: FINRAOS/herd

  1. @Override
  2.   public Upload answer(InvocationOnMock invocation) throws Throwable
  3.   {
  4.     Upload mockedUpload = mock(Upload.class);
  5.     TransferProgress transferProgress = new TransferProgress();
  6.     // bytesTransferred < totalBytesToTransfer should cause error
  7.     ReflectionTestUtils.setField(transferProgress, "bytesTransferred", 0l);
  8.     ReflectionTestUtils.setField(transferProgress, "totalBytesToTransfer", 1l);
  9.     when(mockedUpload.getProgress()).thenReturn(transferProgress);
  10.     when(mockedUpload.isDone()).thenReturn(true);
  11.     when(mockedUpload.getState()).thenReturn(TransferState.Completed);
  12.     return mockedUpload;
  13.   }
  14. });

代码示例来源：origin: org.apache.hadoop/hadoop-aws

  1. @Override
  2. public void progressChanged(ProgressEvent progressEvent) {
  3.  if (progress != null) {
  4.   progress.progress();
  5.  }
  6.  // There are 3 http ops here, but this should be close enough for now
  7.  ProgressEventType pet = progressEvent.getEventType();
  8.  if (pet == TRANSFER_PART_STARTED_EVENT ||
  9.    pet == TRANSFER_COMPLETED_EVENT) {
  10.   fs.incrementWriteOperations();
  11.  }
  12.  long transferred = upload.getProgress().getBytesTransferred();
  13.  long delta = transferred - lastBytesTransferred;
  14.  fs.incrementPutProgressStatistics(key, delta);
  15.  lastBytesTransferred = transferred;
  16. }

代码示例来源：origin: com.conveyal/r5

  1. @Override
  2.   public void progressChanged(ProgressEvent progressEvent) {
  3.     final ProgressEventType eventType = progressEvent.getEventType();
  4.     if (eventType == ProgressEventType.REQUEST_BYTE_TRANSFER_EVENT ||
  5.       eventType == ProgressEventType.TRANSFER_COMPLETED_EVENT) {
  6.       long now = System.currentTimeMillis();
  7.       if (now > lastLogTime + LOG_INTERVAL_SECONDS * 1000 ||
  8.         eventType == ProgressEventType.TRANSFER_COMPLETED_EVENT) {
  9.         TransferProgress transferProgress = upload.getProgress();
  10.         double durationSec = (now - beginTime) / 1000D;
  11.         LOG.info("{} transferred {} of {} ({} percent), duration {}, speed {})",
  12.             upload.getDescription(),
  13.             human(transferProgress.getBytesTransferred(), "B"),
  14.             human(transferProgress.getTotalBytesToTransfer(), "B"),
  15.             transferProgress.getPercentTransferred(),
  16.             human(durationSec, "s"),
  17.             human(transferProgress.getBytesTransferred() / durationSec, "B/sec"));
  18.         lastLogTime = now;
  19.       }
  20.     } else if (eventType == ProgressEventType.TRANSFER_FAILED_EVENT) {
  21.       LOG.error("{}: TRANSFER FAILED.", upload.getDescription());
  22.     }
  23.   }
  24. }

代码示例来源：origin: ch.cern.hadoop/hadoop-aws

  1. public void progressChanged(ProgressEvent progressEvent) {
  2.  if (progress != null) {
  3.   progress.progress();
  4.  }
  5.  // There are 3 http ops here, but this should be close enough for now
  6.  if (progressEvent.getEventCode() == ProgressEvent.PART_STARTED_EVENT_CODE ||
  7.    progressEvent.getEventCode() == ProgressEvent.COMPLETED_EVENT_CODE) {
  8.   statistics.incrementWriteOps(1);
  9.  }
  10.  long transferred = upload.getProgress().getBytesTransferred();
  11.  long delta = transferred - lastBytesTransferred;
  12.  if (statistics != null && delta != 0) {
  13.   statistics.incrementBytesWritten(delta);
  14.  }
  15.  lastBytesTransferred = transferred;
  16. }

代码示例来源：origin: Aloisius/hadoop-s3a

  1. long delta = upload.getProgress().getBytesTransferred() - listener.getLastBytesTransferred();
  2. if (statistics != null && delta != 0) {
  3.  if (LOG.isDebugEnabled()) {

代码示例来源：origin: conveyal/r5

  1. @Override
  2.   public void progressChanged(ProgressEvent progressEvent) {
  3.     final ProgressEventType eventType = progressEvent.getEventType();
  4.     if (eventType == ProgressEventType.REQUEST_BYTE_TRANSFER_EVENT ||
  5.       eventType == ProgressEventType.TRANSFER_COMPLETED_EVENT) {
  6.       long now = System.currentTimeMillis();
  7.       if (now > lastLogTime + LOG_INTERVAL_SECONDS * 1000 ||
  8.         eventType == ProgressEventType.TRANSFER_COMPLETED_EVENT) {
  9.         TransferProgress transferProgress = upload.getProgress();
  10.         double durationSec = (now - beginTime) / 1000D;
  11.         LOG.info("{} transferred {} of {} ({} percent), duration {}, speed {})",
  12.             upload.getDescription(),
  13.             human(transferProgress.getBytesTransferred(), "B"),
  14.             human(transferProgress.getTotalBytesToTransfer(), "B"),
  15.             transferProgress.getPercentTransferred(),
  16.             human(durationSec, "s"),
  17.             human(transferProgress.getBytesTransferred() / durationSec, "B/sec"));
  18.         lastLogTime = now;
  19.       }
  20.     } else if (eventType == ProgressEventType.TRANSFER_FAILED_EVENT) {
  21.       LOG.error("{}: TRANSFER FAILED.", upload.getDescription());
  22.     }
  23.   }
  24. }

代码示例来源：origin: Aloisius/hadoop-s3a

  1. public void progressChanged(ProgressEvent progressEvent) {
  2.  if (progress != null) {
  3.   progress.progress();
  4.  }
  5.  // There are 3 http ops here, but this should be close enough for now
  6.  if (progressEvent.getEventCode() == ProgressEvent.PART_STARTED_EVENT_CODE ||
  7.    progressEvent.getEventCode() == ProgressEvent.COMPLETED_EVENT_CODE) {
  8.   statistics.incrementWriteOps(1);
  9.  }
  10.  long transferred = upload.getProgress().getBytesTransferred();
  11.  long delta = transferred - lastBytesTransferred;
  12.  if (statistics != null && delta != 0) {
  13.   statistics.incrementBytesWritten(delta);
  14.  }
  15.  lastBytesTransferred = transferred;
  16. }

内容来源于网络，如有侵权，请联系作者删除！

upload

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com