org.apache.hadoop.hdfs.server.namenode.ha.proto.HAZKInfoProtos.ActiveNodeInfo的实例源码

项目：hadoop    文件：DFSZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  NNHAServiceTarget ret = new NNHAServiceTarget(
      conf,proto.getNameserviceId(),proto.getNamenodeId());
  InetSocketAddress addressFromProtobuf = new InetSocketAddress(
      proto.getHostname(),proto.getPort());

  if (!addressFromProtobuf.equals(ret.getAddress())) {
    throw new RuntimeException("Mismatched address stored in ZK for " +
        ret + ": Stored protobuf was " + proto + ",address from our own " +
        "configuration for this NameNode was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：aliyun-oss-hadoop-fs    文件：DFSZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  NNHAServiceTarget ret = new NNHAServiceTarget(
      conf,address from our own " +
        "configuration for this NameNode was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：big-c    文件：DFSZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  NNHAServiceTarget ret = new NNHAServiceTarget(
      conf,address from our own " +
        "configuration for this NameNode was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：hadoop-2.6.0-cdh5.4.3    文件：DFSZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  NNHAServiceTarget ret = new NNHAServiceTarget(
      conf,address from our own " +
        "configuration for this NameNode was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：hadoop-2.6.0-cdh5.4.3    文件：MRZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  JobTrackerHAServiceTarget ret = new JobTrackerHAServiceTarget(
      conf,proto.getPort());

  if (!addressFromProtobuf.equals(ret.getAddress())) {
    throw new RuntimeException("Mismatched address stored in ZK for " +
        ret + ": Stored protobuf was " + addressFromProtobuf + ",address from our own " +
        "configuration for this JobTracker was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：hadoop-plus    文件：DFSZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  NNHAServiceTarget ret = new NNHAServiceTarget(
      conf,address from our own " +
        "configuration for this NameNode was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：FlexMap    文件：DFSZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  NNHAServiceTarget ret = new NNHAServiceTarget(
      conf,address from our own " +
        "configuration for this NameNode was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：hadoop-TCP    文件：DFSZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  NNHAServiceTarget ret = new NNHAServiceTarget(
      conf,address from our own " +
        "configuration for this NameNode was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：hardfs    文件：DFSZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  NNHAServiceTarget ret = new NNHAServiceTarget(
      conf,address from our own " +
        "configuration for this NameNode was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：hadoop-on-lustre2    文件：DFSZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  NNHAServiceTarget ret = new NNHAServiceTarget(
      conf,address from our own " +
        "configuration for this NameNode was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：hanoi-hadoop-2.0.0-cdh    文件：MRZKFailoverController.java   

@Override
protected HAServiceTarget dataToTarget(byte[] data) {
  ActiveNodeInfo proto;
  try {
    proto = ActiveNodeInfo.parseFrom(data);
  } catch (InvalidProtocolBufferException e) {
    throw new RuntimeException("Invalid data in ZK: " +
        StringUtils.bytetoHexString(data));
  }
  JobTrackerHAServiceTarget ret = new JobTrackerHAServiceTarget(
      conf,address from our own " +
        "configuration for this JobTracker was " + ret.getAddress());
  }

  ret.setZkfcPort(proto.getZkfcPort());
  return ret;
}

项目：hadoop    文件：DFSZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localNNTarget.getNameServiceId())
    .setNamenodeId(localNNTarget.getNameNodeId())
    .build()
    .toByteArray();
}

项目：aliyun-oss-hadoop-fs    文件：DFSZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localNNTarget.getNameServiceId())
    .setNamenodeId(localNNTarget.getNameNodeId())
    .build()
    .toByteArray();
}

项目：big-c    文件：DFSZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localNNTarget.getNameServiceId())
    .setNamenodeId(localNNTarget.getNameNodeId())
    .build()
    .toByteArray();
}

项目：hadoop-2.6.0-cdh5.4.3    文件：DFSZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localNNTarget.getNameServiceId())
    .setNamenodeId(localNNTarget.getNameNodeId())
    .build()
    .toByteArray();
}

项目：hadoop-2.6.0-cdh5.4.3    文件：MRZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localJTTarget.getLogicalName())
    .setNamenodeId(localJTTarget.getJobTrackerId())
    .build()
    .toByteArray();
}

项目：hadoop-plus    文件：DFSZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localNNTarget.getNameServiceId())
    .setNamenodeId(localNNTarget.getNameNodeId())
    .build()
    .toByteArray();
}

项目：FlexMap    文件：DFSZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localNNTarget.getNameServiceId())
    .setNamenodeId(localNNTarget.getNameNodeId())
    .build()
    .toByteArray();
}

项目：hadoop-TCP    文件：DFSZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localNNTarget.getNameServiceId())
    .setNamenodeId(localNNTarget.getNameNodeId())
    .build()
    .toByteArray();
}

项目：hardfs    文件：DFSZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localNNTarget.getNameServiceId())
    .setNamenodeId(localNNTarget.getNameNodeId())
    .build()
    .toByteArray();
}

项目：hadoop-on-lustre2    文件：DFSZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localNNTarget.getNameServiceId())
    .setNamenodeId(localNNTarget.getNameNodeId())
    .build()
    .toByteArray();
}

项目：hanoi-hadoop-2.0.0-cdh    文件：MRZKFailoverController.java   

@Override
protected byte[] targetToData(HAServiceTarget target) {
  InetSocketAddress addr = target.getAddress();

  return ActiveNodeInfo.newBuilder()
    .setHostname(addr.getHostName())
    .setPort(addr.getPort())
    .setZkfcPort(target.getZKFCAddress().getPort())
    .setNameserviceId(localJTTarget.getLogicalName())
    .setNamenodeId(localJTTarget.getJobTrackerId())
    .build()
    .toByteArray();
}