hadoop BlockReportContext 源码

  • 2022-10-20
  • 浏览 (55)

haddop BlockReportContext 代码


 * Licensed to the Apache Software Foundation (ASF) under one
 * or more contributor license agreements.  See the NOTICE file
 * distributed with this work for additional information
 * regarding copyright ownership.  The ASF licenses this file
 * to you under the Apache License, Version 2.0 (the
 * "License"); you may not use this file except in compliance
 * with the License.  You may obtain a copy of the License at
 *     http://www.apache.org/licenses/LICENSE-2.0
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * See the License for the specific language governing permissions and
 * limitations under the License.

package org.apache.hadoop.hdfs.server.protocol;

import org.apache.hadoop.classification.InterfaceAudience;

 * The context of the block report.
 * This is a set of fields that the Datanode sends to provide context about a
 * block report RPC.  The context includes a unique 64-bit ID which
 * identifies the block report as a whole.  It also includes the total number
 * of RPCs which this block report is split into, and the index into that
 * total for the current RPC.
public class BlockReportContext {
   * The total number of RPCs contained in the block report.
  private final int totalRpcs;

   * The index of this particular RPC.
  private final int curRpc;

   * A 64-bit ID which identifies the block report as a whole.
  private final long reportId;

   * The lease ID which this block report is using, or 0 if this block report is
   * bypassing rate-limiting.
  private final long leaseId;

  public BlockReportContext(int totalRpcs, int curRpc,
                            long reportId, long leaseId) {
    this.totalRpcs = totalRpcs;
    this.curRpc = curRpc;
    this.reportId = reportId;
    this.leaseId = leaseId;

  public int getTotalRpcs() {
    return totalRpcs;

  public int getCurRpc() {
    return curRpc;

  public long getReportId() {
    return reportId;

  public long getLeaseId() {
    return leaseId;


hadoop 源码目录


hadoop BalancerBandwidthCommand 源码

hadoop BalancerProtocols 源码

hadoop BlockCommand 源码

hadoop BlockECReconstructionCommand 源码

hadoop BlockIdCommand 源码

hadoop BlockRecoveryCommand 源码

hadoop BlockStorageMovementCommand 源码

hadoop BlocksStorageMoveAttemptFinished 源码

hadoop BlocksWithLocations 源码

hadoop CheckpointCommand 源码

0  赞