Java 类org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.ClientReadStatusProto 实例源码

项目：hadoop 文件：RemoteBlockReader2.java

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder()
    .setStatus(statusCode)
    .build()
    .writeDelimitedTo(out);

  out.flush();
}

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

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder()
      .setStatus(statusCode)
      .build()
      .writeDelimitedTo(out);

  out.flush();
}

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

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder()
    .setStatus(statusCode)
    .build()
    .writeDelimitedTo(out);

  out.flush();
}

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

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder()
    .setStatus(statusCode)
    .build()
    .writeDelimitedTo(out);

  out.flush();
}

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

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder()
    .setStatus(statusCode)
    .build()
    .writeDelimitedTo(out);

  out.flush();
}

项目：FlexMap 文件：RemoteBlockReader2.java

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder()
    .setStatus(statusCode)
    .build()
    .writeDelimitedTo(out);

  out.flush();
}

项目：hops 文件：RemoteBlockReader2.java

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder().setStatus(statusCode).build()
      .writeDelimitedTo(out);

  out.flush();
}

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

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder()
    .setStatus(statusCode)
    .build()
    .writeDelimitedTo(out);

  out.flush();
}

项目：hardfs 文件：RemoteBlockReader2.java

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder()
    .setStatus(statusCode)
    .build()
    .writeDelimitedTo(out);

  out.flush();
}

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

/**
 * Serialize the actual read result on the wire.
 */
static void writeReadResult(OutputStream out, Status statusCode)
    throws IOException {

  ClientReadStatusProto.newBuilder()
    .setStatus(statusCode)
    .build()
    .writeDelimitedTo(out);

  out.flush();
}