Java 类org.apache.hadoop.io.DataOutputOutputStream 实例源码

项目：hadoop-oss 文件：ProtobufRpcEngine.java

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}

项目：incubator-ratis 文件：ProtobufRpcEngineShaded.java

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}

项目：hadoop 文件：ProtobufRpcEngine.java

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}

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

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}

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

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}

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

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}

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

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}

项目：bigsolr 文件：SolrRecord.java

@Override
public void write(DataOutput out) throws IOException {
  log.debug("SolrRecord -> write");

  JavaBinCodec codec = new JavaBinCodec();
  FastOutputStream os = FastOutputStream.wrap(DataOutputOutputStream.constructOutputStream(out));
  codec.init(os);
  try {
    codec.writeVal(sd);
  } finally {
    os.flushBuffer();
  }
}

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

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}

项目：hardfs 文件：ProtobufRpcEngine.java

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}

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

@Override
public void write(DataOutput out) throws IOException {
  OutputStream os = DataOutputOutputStream.constructOutputStream(out);

  ((Message)requestHeader).writeDelimitedTo(os);
  theRequest.writeDelimitedTo(os);
}