Java 类org.apache.hadoop.hdfs.protocol.proto.HdfsProtos.RemoteEditLogManifestProto 实例源码

项目:hadoop    文件:PBHelper.java   
public static RemoteEditLogManifestProto convert(
    RemoteEditLogManifest manifest) {
  RemoteEditLogManifestProto.Builder builder = RemoteEditLogManifestProto
      .newBuilder();
  for (RemoteEditLog log : manifest.getLogs()) {
    builder.addLogs(convert(log));
  }
  return builder.build();
}
项目:hadoop    文件:PBHelper.java   
public static RemoteEditLogManifest convert(
    RemoteEditLogManifestProto manifest) {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>(manifest
      .getLogsList().size());
  for (RemoteEditLogProto l : manifest.getLogsList()) {
    logs.add(convert(l));
  }
  return new RemoteEditLogManifest(logs);
}
项目:hadoop    文件:TestPBHelper.java   
@Test
public void testConvertRemoteEditLogManifest() {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>();
  logs.add(new RemoteEditLog(1, 10));
  logs.add(new RemoteEditLog(11, 20));
  RemoteEditLogManifest m = new RemoteEditLogManifest(logs);
  RemoteEditLogManifestProto mProto = PBHelper.convert(m);
  RemoteEditLogManifest m1 = PBHelper.convert(mProto);

  List<RemoteEditLog> logs1 = m1.getLogs();
  assertEquals(logs.size(), logs1.size());
  for (int i = 0; i < logs.size(); i++) {
    compare(logs.get(i), logs1.get(i));
  }
}
项目:big-c    文件:PBHelper.java   
public static RemoteEditLogManifestProto convert(
    RemoteEditLogManifest manifest) {
  RemoteEditLogManifestProto.Builder builder = RemoteEditLogManifestProto
      .newBuilder();
  for (RemoteEditLog log : manifest.getLogs()) {
    builder.addLogs(convert(log));
  }
  return builder.build();
}
项目:big-c    文件:PBHelper.java   
public static RemoteEditLogManifest convert(
    RemoteEditLogManifestProto manifest) {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>(manifest
      .getLogsList().size());
  for (RemoteEditLogProto l : manifest.getLogsList()) {
    logs.add(convert(l));
  }
  return new RemoteEditLogManifest(logs);
}
项目:big-c    文件:TestPBHelper.java   
@Test
public void testConvertRemoteEditLogManifest() {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>();
  logs.add(new RemoteEditLog(1, 10));
  logs.add(new RemoteEditLog(11, 20));
  RemoteEditLogManifest m = new RemoteEditLogManifest(logs);
  RemoteEditLogManifestProto mProto = PBHelper.convert(m);
  RemoteEditLogManifest m1 = PBHelper.convert(mProto);

  List<RemoteEditLog> logs1 = m1.getLogs();
  assertEquals(logs.size(), logs1.size());
  for (int i = 0; i < logs.size(); i++) {
    compare(logs.get(i), logs1.get(i));
  }
}
项目:hadoop-2.6.0-cdh5.4.3    文件:PBHelper.java   
public static RemoteEditLogManifestProto convert(
    RemoteEditLogManifest manifest) {
  RemoteEditLogManifestProto.Builder builder = RemoteEditLogManifestProto
      .newBuilder();
  for (RemoteEditLog log : manifest.getLogs()) {
    builder.addLogs(convert(log));
  }
  return builder.build();
}
项目:hadoop-2.6.0-cdh5.4.3    文件:PBHelper.java   
public static RemoteEditLogManifest convert(
    RemoteEditLogManifestProto manifest) {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>(manifest
      .getLogsList().size());
  for (RemoteEditLogProto l : manifest.getLogsList()) {
    logs.add(convert(l));
  }
  return new RemoteEditLogManifest(logs);
}
项目:hadoop-2.6.0-cdh5.4.3    文件:TestPBHelper.java   
@Test
public void testConvertRemoteEditLogManifest() {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>();
  logs.add(new RemoteEditLog(1, 10));
  logs.add(new RemoteEditLog(11, 20));
  RemoteEditLogManifest m = new RemoteEditLogManifest(logs);
  RemoteEditLogManifestProto mProto = PBHelper.convert(m);
  RemoteEditLogManifest m1 = PBHelper.convert(mProto);

  List<RemoteEditLog> logs1 = m1.getLogs();
  assertEquals(logs.size(), logs1.size());
  for (int i = 0; i < logs.size(); i++) {
    compare(logs.get(i), logs1.get(i));
  }
}
项目:hadoop-plus    文件:PBHelper.java   
public static RemoteEditLogManifestProto convert(
    RemoteEditLogManifest manifest) {
  RemoteEditLogManifestProto.Builder builder = RemoteEditLogManifestProto
      .newBuilder();
  for (RemoteEditLog log : manifest.getLogs()) {
    builder.addLogs(convert(log));
  }
  return builder.build();
}
项目:hadoop-plus    文件:PBHelper.java   
public static RemoteEditLogManifest convert(
    RemoteEditLogManifestProto manifest) {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>(manifest
      .getLogsList().size());
  for (RemoteEditLogProto l : manifest.getLogsList()) {
    logs.add(convert(l));
  }
  return new RemoteEditLogManifest(logs);
}
项目:hadoop-plus    文件:TestPBHelper.java   
@Test
public void testConvertRemoteEditLogManifest() {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>();
  logs.add(new RemoteEditLog(1, 10));
  logs.add(new RemoteEditLog(11, 20));
  RemoteEditLogManifest m = new RemoteEditLogManifest(logs);
  RemoteEditLogManifestProto mProto = PBHelper.convert(m);
  RemoteEditLogManifest m1 = PBHelper.convert(mProto);

  List<RemoteEditLog> logs1 = m1.getLogs();
  assertEquals(logs.size(), logs1.size());
  for (int i = 0; i < logs.size(); i++) {
    compare(logs.get(i), logs1.get(i));
  }
}
项目:FlexMap    文件:PBHelper.java   
public static RemoteEditLogManifestProto convert(
    RemoteEditLogManifest manifest) {
  RemoteEditLogManifestProto.Builder builder = RemoteEditLogManifestProto
      .newBuilder();
  for (RemoteEditLog log : manifest.getLogs()) {
    builder.addLogs(convert(log));
  }
  return builder.build();
}
项目:FlexMap    文件:PBHelper.java   
public static RemoteEditLogManifest convert(
    RemoteEditLogManifestProto manifest) {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>(manifest
      .getLogsList().size());
  for (RemoteEditLogProto l : manifest.getLogsList()) {
    logs.add(convert(l));
  }
  return new RemoteEditLogManifest(logs);
}
项目:FlexMap    文件:TestPBHelper.java   
@Test
public void testConvertRemoteEditLogManifest() {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>();
  logs.add(new RemoteEditLog(1, 10));
  logs.add(new RemoteEditLog(11, 20));
  RemoteEditLogManifest m = new RemoteEditLogManifest(logs);
  RemoteEditLogManifestProto mProto = PBHelper.convert(m);
  RemoteEditLogManifest m1 = PBHelper.convert(mProto);

  List<RemoteEditLog> logs1 = m1.getLogs();
  assertEquals(logs.size(), logs1.size());
  for (int i = 0; i < logs.size(); i++) {
    compare(logs.get(i), logs1.get(i));
  }
}
项目:hadoop-TCP    文件:PBHelper.java   
public static RemoteEditLogManifestProto convert(
    RemoteEditLogManifest manifest) {
  RemoteEditLogManifestProto.Builder builder = RemoteEditLogManifestProto
      .newBuilder();
  for (RemoteEditLog log : manifest.getLogs()) {
    builder.addLogs(convert(log));
  }
  return builder.build();
}
项目:hadoop-TCP    文件:PBHelper.java   
public static RemoteEditLogManifest convert(
    RemoteEditLogManifestProto manifest) {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>(manifest
      .getLogsList().size());
  for (RemoteEditLogProto l : manifest.getLogsList()) {
    logs.add(convert(l));
  }
  return new RemoteEditLogManifest(logs);
}
项目:hadoop-TCP    文件:TestPBHelper.java   
@Test
public void testConvertRemoteEditLogManifest() {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>();
  logs.add(new RemoteEditLog(1, 10));
  logs.add(new RemoteEditLog(11, 20));
  RemoteEditLogManifest m = new RemoteEditLogManifest(logs);
  RemoteEditLogManifestProto mProto = PBHelper.convert(m);
  RemoteEditLogManifest m1 = PBHelper.convert(mProto);

  List<RemoteEditLog> logs1 = m1.getLogs();
  assertEquals(logs.size(), logs1.size());
  for (int i = 0; i < logs.size(); i++) {
    compare(logs.get(i), logs1.get(i));
  }
}
项目:hardfs    文件:PBHelper.java   
public static RemoteEditLogManifestProto convert(
    RemoteEditLogManifest manifest) {
  RemoteEditLogManifestProto.Builder builder = RemoteEditLogManifestProto
      .newBuilder();
  for (RemoteEditLog log : manifest.getLogs()) {
    builder.addLogs(convert(log));
  }
  return builder.build();
}
项目:hardfs    文件:PBHelper.java   
public static RemoteEditLogManifest convert(
    RemoteEditLogManifestProto manifest) {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>(manifest
      .getLogsList().size());
  for (RemoteEditLogProto l : manifest.getLogsList()) {
    logs.add(convert(l));
  }
  return new RemoteEditLogManifest(logs);
}
项目:hardfs    文件:TestPBHelper.java   
@Test
public void testConvertRemoteEditLogManifest() {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>();
  logs.add(new RemoteEditLog(1, 10));
  logs.add(new RemoteEditLog(11, 20));
  RemoteEditLogManifest m = new RemoteEditLogManifest(logs);
  RemoteEditLogManifestProto mProto = PBHelper.convert(m);
  RemoteEditLogManifest m1 = PBHelper.convert(mProto);

  List<RemoteEditLog> logs1 = m1.getLogs();
  assertEquals(logs.size(), logs1.size());
  for (int i = 0; i < logs.size(); i++) {
    compare(logs.get(i), logs1.get(i));
  }
}
项目:hadoop-on-lustre2    文件:PBHelper.java   
public static RemoteEditLogManifestProto convert(
    RemoteEditLogManifest manifest) {
  RemoteEditLogManifestProto.Builder builder = RemoteEditLogManifestProto
      .newBuilder();
  for (RemoteEditLog log : manifest.getLogs()) {
    builder.addLogs(convert(log));
  }
  return builder.build();
}
项目:hadoop-on-lustre2    文件:PBHelper.java   
public static RemoteEditLogManifest convert(
    RemoteEditLogManifestProto manifest) {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>(manifest
      .getLogsList().size());
  for (RemoteEditLogProto l : manifest.getLogsList()) {
    logs.add(convert(l));
  }
  return new RemoteEditLogManifest(logs);
}
项目:hadoop-on-lustre2    文件:TestPBHelper.java   
@Test
public void testConvertRemoteEditLogManifest() {
  List<RemoteEditLog> logs = new ArrayList<RemoteEditLog>();
  logs.add(new RemoteEditLog(1, 10));
  logs.add(new RemoteEditLog(11, 20));
  RemoteEditLogManifest m = new RemoteEditLogManifest(logs);
  RemoteEditLogManifestProto mProto = PBHelper.convert(m);
  RemoteEditLogManifest m1 = PBHelper.convert(mProto);

  List<RemoteEditLog> logs1 = m1.getLogs();
  assertEquals(logs.size(), logs1.size());
  for (int i = 0; i < logs.size(); i++) {
    compare(logs.get(i), logs1.get(i));
  }
}