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

Progress.set介绍

[英]Called during execution on a leaf node to set its progress.
[中]在叶节点上执行期间调用以设置其进度。

代码示例

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

private void updateProgress(long bytesProcessed) {
 totalBytesProcessed += bytesProcessed;
 if (progPerByte > 0) {
  mergeProgress.set(totalBytesProcessed * progPerByte);
 }
}

代码示例来源：origin: org.apache.tez/tez-runtime-library

@Override
 public void set(float progress) {
  if (progress != currentProgress) {
   currentProgress = progress;
   // enter lock section
   super.set(progress);
  }
 }
}

代码示例来源：origin: io.hops/hadoop-common

private void updateProgress(long bytesProcessed) {
 totalBytesProcessed += bytesProcessed;
 if (progPerByte > 0) {
  mergeProgress.set(totalBytesProcessed * progPerByte);
 }
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

private void updateProgress(long bytesProcessed) {
 totalBytesProcessed += bytesProcessed;
 if (progPerByte > 0) {
  mergeProgress.set(totalBytesProcessed * progPerByte);
 }
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

private void updateProgress(long bytesProcessed) {
 totalBytesProcessed += bytesProcessed;
 if (progPerByte > 0) {
  mergeProgress.set(totalBytesProcessed * progPerByte);
 }
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

private void updateProgress(long bytesProcessed) {
 totalBytesProcessed += bytesProcessed;
 if (progPerByte > 0) {
  mergeProgress.set(totalBytesProcessed * progPerByte);
 }
}

代码示例来源：origin: io.snappydata/gemfire-core

private void updateProgress(long bytesProcessed) {
 totalBytesProcessed += bytesProcessed;
 if (progPerByte > 0) {
  mergeProgress.set(totalBytesProcessed * progPerByte);
 }
}

代码示例来源：origin: org.apache.geode/gemfire-core

private void updateProgress(long bytesProcessed) {
 totalBytesProcessed += bytesProcessed;
 if (progPerByte > 0) {
  mergeProgress.set(totalBytesProcessed * progPerByte);
 }
}

代码示例来源：origin: org.jvnet.hudson.hadoop/hadoop-core

public void setProgress(float progress) {
 taskProgress.set(progress);
 // indicate that progress update needs to be sent
 setProgressFlag();
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

public void setProgress(float progress) {
 taskProgress.set(progress);
 // indicate that progress update needs to be sent
 setProgressFlag();
}
public void progress() {

代码示例来源：origin: com.github.jiayuhan-it/hadoop-mapreduce-client-core

public void setProgress(float progress) {
 // set current phase progress.
 // This method assumes that task has phases.
 taskProgress.phase().set(progress);
 // indicate that progress update needs to be sent
 setProgressFlag();
}

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

public void setProgress(float progress) {
 // set current phase progress.
 // This method assumes that task has phases.
 taskProgress.phase().set(progress);
 // indicate that progress update needs to be sent
 setProgressFlag();
}
public void progress() {

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

public void setProgress(float progress) {
 // set current phase progress.
 // This method assumes that task has phases.
 taskProgress.phase().set(progress);
 // indicate that progress update needs to be sent
 setProgressFlag();
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-core

public void setProgress(float progress) {
 // set current phase progress.
 // This method assumes that task has phases.
 taskProgress.phase().set(progress);
 // indicate that progress update needs to be sent
 setProgressFlag();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-mapreduce-client-core

public void informReduceProgress() {
  reducePhase.set(super.in.getProgress().getProgress()); // update progress
  reporter.progress();
 }
}

代码示例来源：origin: org.jvnet.hudson.hadoop/hadoop-core

public void informReduceProgress() {
  reducePhase.set(super.in.getProgress().get()); // update progress
  reporter.progress();
 }
}

代码示例来源：origin: io.hops/hadoop-mapreduce-client-core

public void informReduceProgress() {
  reducePhase.set(super.in.getProgress().getProgress()); // update progress
  reporter.progress();
 }
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

public void informReduceProgress() {
  reducePhase.set(super.in.getProgress().get()); // update progress
  reporter.progress();
 }
}

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

public void informReduceProgress() {
  reducePhase.set(super.in.getProgress().getProgress()); // update progress
  reporter.progress();
 }
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

public boolean next() throws IOException {
 long startBytesProcessed = rawIter.getTotalBytesProcessed();
 boolean ret = rawIter.next();
 long endBytesProcessed = rawIter.getTotalBytesProcessed();
 reduceInputBytesCounter.increment(
   endBytesProcessed - startBytesProcessed);
 reducePhase.set(rawIter.getProgress().get());
 reporter.progress();
 return ret;
}
public long getTotalBytesProcessed() {