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();
}