hadoop FederationNamespaceInfo 源码

haddop FederationNamespaceInfo 代码

文件路径：/hadoop-hdfs-project/hadoop-hdfs-rbf/src/main/java/org/apache/hadoop/hdfs/server/federation/resolver/FederationNamespaceInfo.java

/**
 * 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,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */
package org.apache.hadoop.hdfs.server.federation.resolver;

import org.apache.commons.lang3.builder.CompareToBuilder;
import org.apache.commons.lang3.builder.EqualsBuilder;
import org.apache.commons.lang3.builder.HashCodeBuilder;
import org.apache.hadoop.hdfs.server.federation.router.RemoteLocationContext;

/**
 * Represents information about a single nameservice/namespace in a federated
 * HDFS cluster.
 */
public class FederationNamespaceInfo extends RemoteLocationContext {

  /** Block pool identifier. */
  private final String blockPoolId;
  /** Cluster identifier. */
  private final String clusterId;
  /** Nameservice identifier. */
  private final String nameserviceId;

  public FederationNamespaceInfo(String bpId, String clId, String nsId) {
    this.blockPoolId = bpId;
    this.clusterId = clId;
    this.nameserviceId = nsId;
  }

  @Override
  public String getNameserviceId() {
    return this.nameserviceId;
  }

  @Override
  public String getDest() {
    return this.nameserviceId;
  }

  @Override
  public String getSrc() {
    return null;
  }

  /**
   * The HDFS cluster id for this namespace.
   *
   * @return Cluster identifier.
   */
  public String getClusterId() {
    return this.clusterId;
  }

  /**
   * The HDFS block pool id for this namespace.
   *
   * @return Block pool identifier.
   */
  public String getBlockPoolId() {
    return this.blockPoolId;
  }

  @Override
  public String toString() {
    return this.nameserviceId + "->" + this.blockPoolId + ":" + this.clusterId;
  }

  @Override
  public boolean equals(Object obj) {
    if (obj == null) {
      return false;
    }
    if (obj == this) {
      return true;
    }
    if (obj.getClass() != getClass()) {
      return false;
    }
    FederationNamespaceInfo other = (FederationNamespaceInfo) obj;
    return new EqualsBuilder()
        .append(nameserviceId, other.nameserviceId)
        .append(clusterId, other.clusterId)
        .append(blockPoolId, other.blockPoolId)
        .isEquals();
  }

  @Override
  public int hashCode() {
    return new HashCodeBuilder(17, 31)
        .append(nameserviceId)
        .append(clusterId)
        .append(blockPoolId)
        .toHashCode();
  }

  @Override
  public int compareTo(RemoteLocationContext info) {
    if (info instanceof FederationNamespaceInfo) {
      FederationNamespaceInfo other = (FederationNamespaceInfo) info;
      return new CompareToBuilder()
          .append(nameserviceId, other.nameserviceId)
          .append(clusterId, other.clusterId)
          .append(blockPoolId, other.blockPoolId)
          .toComparison();
    }
    return super.compareTo(info);
  }
}

相关信息

hadoop 源码目录

相关文章

hadoop ActiveNamenodeResolver 源码

hadoop FederationNamenodeContext 源码

hadoop FederationNamenodeServiceState 源码

hadoop FileSubclusterResolver 源码

hadoop MembershipNamenodeResolver 源码

hadoop MountTableManager 源码

hadoop MountTableResolver 源码

hadoop MultipleDestinationMountTableResolver 源码

hadoop NamenodePriorityComparator 源码

hadoop NamenodeStatusReport 源码