org.apache.hadoop.record.Buffer.append()方法的使用及代码示例

x33g5p2x  于2022-01-17 转载在 其他  
字(8.0k)|赞(0)|评价(0)|浏览(90)

本文整理了Java中org.apache.hadoop.record.Buffer.append()方法的一些代码示例，展示了Buffer.append()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Buffer.append()方法的具体详情如下：
包路径：org.apache.hadoop.record.Buffer
类名称：Buffer
方法名：append

Buffer.append介绍

[英]Append specified bytes to the buffer
[中]将指定的字节追加到缓冲区

代码示例

代码示例来源：origin: ch.cern.hadoop/hadoop-common

/**
 * Append specified bytes to the buffer
 *
 * @param bytes byte array to be appended
 */
public void append(byte[] bytes) {
 append(bytes, 0, bytes.length);
}

代码示例来源：origin: com.github.jiayuhan-it/hadoop-common

/**
 * Append specified bytes to the buffer
 *
 * @param bytes byte array to be appended
 */
public void append(byte[] bytes) {
 append(bytes, 0, bytes.length);
}

代码示例来源：origin: com.facebook.hadoop/hadoop-core

/**
 * Append specified bytes to the buffer
 *
 * @param bytes byte array to be appended
 */
public void append(byte[] bytes) {
 append(bytes, 0, bytes.length);
}

代码示例来源：origin: io.prestosql.hadoop/hadoop-apache

/**
 * Append specified bytes to the buffer
 *
 * @param bytes byte array to be appended
 */
public void append(byte[] bytes) {
 append(bytes, 0, bytes.length);
}

代码示例来源：origin: org.jvnet.hudson.hadoop/hadoop-core

/**
 * Append specified bytes to the buffer
 *
 * @param bytes byte array to be appended
 */
public void append(byte[] bytes) {
 append(bytes, 0, bytes.length);
}

代码示例来源：origin: org.apache.hadoop/hadoop-streaming

/**
 * Append specified bytes to the buffer
 *
 * @param bytes byte array to be appended
 */
public void append(byte[] bytes) {
 append(bytes, 0, bytes.length);
}

代码示例来源：origin: io.hops/hadoop-common

/**
 * Append specified bytes to the buffer
 *
 * @param bytes byte array to be appended
 */
public void append(byte[] bytes) {
 append(bytes, 0, bytes.length);
}

代码示例来源：origin: edu.berkeley.cs.shark/hive-contrib

/**
 * Reads the raw bytes following a <code>Type.MAP</code> code.
 * 
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawMap() throws IOException {
 Buffer buffer = new Buffer();
 int length = readMapHeader();
 buffer.append(new byte[] {(byte) Type.MAP.code,
   (byte) (0xff & (length >> 24)), (byte) (0xff & (length >> 16)),
   (byte) (0xff & (length >> 8)), (byte) (0xff & length)});
 for (int i = 0; i < length; i++) {
  buffer.append(readRaw());
  buffer.append(readRaw());
 }
 return buffer.get();
}

代码示例来源：origin: org.apache.hadoop.hive/hive-contrib

/**
 * Reads the raw bytes following a <code>Type.MAP</code> code.
 * 
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawMap() throws IOException {
 Buffer buffer = new Buffer();
 int length = readMapHeader();
 buffer.append(new byte[] {(byte) Type.MAP.code,
   (byte) (0xff & (length >> 24)), (byte) (0xff & (length >> 16)),
   (byte) (0xff & (length >> 8)), (byte) (0xff & length)});
 for (int i = 0; i < length; i++) {
  buffer.append(readRaw());
  buffer.append(readRaw());
 }
 return buffer.get();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-streaming

/**
 * Reads the raw bytes following a <code>Type.VECTOR</code> code.
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawVector() throws IOException {
 Buffer buffer = new Buffer();
 int length = readVectorHeader();
 buffer.append(new byte[] {
  (byte) Type.VECTOR.code,
  (byte) (0xff & (length >> 24)), (byte) (0xff & (length >> 16)),
  (byte) (0xff & (length >> 8)), (byte) (0xff & length)
 });
 for (int i = 0; i < length; i++) {
  buffer.append(readRaw());
 }
 return buffer.get();
}

代码示例来源：origin: org.apache.hadoop/hadoop-streaming

/**
 * Reads the raw bytes following a <code>Type.LIST</code> code.
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawList() throws IOException {
 Buffer buffer = new Buffer(new byte[] { (byte) Type.LIST.code });
 byte[] bytes = readRaw();
 while (bytes != null) {
  buffer.append(bytes);
  bytes = readRaw();
 }
 buffer.append(new byte[] { (byte) Type.MARKER.code });
 return buffer.get();
}

代码示例来源：origin: org.apache.hadoop/hadoop-streaming

/**
 * Reads the raw bytes following a <code>Type.MAP</code> code.
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawMap() throws IOException {
 Buffer buffer = new Buffer();
 int length = readMapHeader();
 buffer.append(new byte[] {
  (byte) Type.MAP.code,
  (byte) (0xff & (length >> 24)), (byte) (0xff & (length >> 16)),
  (byte) (0xff & (length >> 8)), (byte) (0xff & length)
 });
 for (int i = 0; i < length; i++) {
  buffer.append(readRaw());
  buffer.append(readRaw());
 }
 return buffer.get();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-streaming

/**
 * Reads the raw bytes following a <code>Type.LIST</code> code.
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawList() throws IOException {
 Buffer buffer = new Buffer(new byte[] { (byte) Type.LIST.code });
 byte[] bytes = readRaw();
 while (bytes != null) {
  buffer.append(bytes);
  bytes = readRaw();
 }
 buffer.append(new byte[] { (byte) Type.MARKER.code });
 return buffer.get();
}

代码示例来源：origin: ch.cern.hadoop/hadoop-streaming

/**
 * Reads the raw bytes following a <code>Type.MAP</code> code.
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawMap() throws IOException {
 Buffer buffer = new Buffer();
 int length = readMapHeader();
 buffer.append(new byte[] {
  (byte) Type.MAP.code,
  (byte) (0xff & (length >> 24)), (byte) (0xff & (length >> 16)),
  (byte) (0xff & (length >> 8)), (byte) (0xff & length)
 });
 for (int i = 0; i < length; i++) {
  buffer.append(readRaw());
  buffer.append(readRaw());
 }
 return buffer.get();
}

代码示例来源：origin: org.apache.hadoop.hive/hive-contrib

/**
 * Reads the raw bytes following a <code>Type.LIST</code> code.
 * 
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawList() throws IOException {
 Buffer buffer = new Buffer(new byte[] {(byte) Type.LIST.code});
 byte[] bytes = readRaw();
 while (bytes != null) {
  buffer.append(bytes);
  bytes = readRaw();
 }
 buffer.append(new byte[] {(byte) Type.MARKER.code});
 return buffer.get();
}

代码示例来源：origin: edu.berkeley.cs.shark/hive-contrib

/**
 * Reads the raw bytes following a <code>Type.LIST</code> code.
 * 
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawList() throws IOException {
 Buffer buffer = new Buffer(new byte[] {(byte) Type.LIST.code});
 byte[] bytes = readRaw();
 while (bytes != null) {
  buffer.append(bytes);
  bytes = readRaw();
 }
 buffer.append(new byte[] {(byte) Type.MARKER.code});
 return buffer.get();
}

代码示例来源：origin: edu.berkeley.cs.shark/hive-contrib

/**
 * Reads the raw bytes following a <code>Type.VECTOR</code> code.
 * 
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawVector() throws IOException {
 Buffer buffer = new Buffer();
 int length = readVectorHeader();
 buffer.append(new byte[] {(byte) Type.VECTOR.code,
   (byte) (0xff & (length >> 24)), (byte) (0xff & (length >> 16)),
   (byte) (0xff & (length >> 8)), (byte) (0xff & length)});
 for (int i = 0; i < length; i++) {
  buffer.append(readRaw());
 }
 return buffer.get();
}

代码示例来源：origin: org.apache.hadoop.hive/hive-contrib

/**
 * Reads the raw bytes following a <code>Type.VECTOR</code> code.
 * 
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawVector() throws IOException {
 Buffer buffer = new Buffer();
 int length = readVectorHeader();
 buffer.append(new byte[] {(byte) Type.VECTOR.code,
   (byte) (0xff & (length >> 24)), (byte) (0xff & (length >> 16)),
   (byte) (0xff & (length >> 8)), (byte) (0xff & length)});
 for (int i = 0; i < length; i++) {
  buffer.append(readRaw());
 }
 return buffer.get();
}

代码示例来源：origin: org.apache.hadoop/hadoop-streaming

/**
 * Reads the raw bytes following a <code>Type.VECTOR</code> code.
 * @return the obtained bytes sequence
 * @throws IOException
 */
public byte[] readRawVector() throws IOException {
 Buffer buffer = new Buffer();
 int length = readVectorHeader();
 buffer.append(new byte[] {
  (byte) Type.VECTOR.code,
  (byte) (0xff & (length >> 24)), (byte) (0xff & (length >> 16)),
  (byte) (0xff & (length >> 8)), (byte) (0xff & length)
 });
 for (int i = 0; i < length; i++) {
  buffer.append(readRaw());
 }
 return buffer.get();
}

代码示例来源：origin: org.apache.hadoop/hadoop-common-test

/**
  * Test of append method, of class org.apache.hadoop.record.Buffer.
  */
 public void testAppend() {
  final byte[] bytes = new byte[100];
  final int offset = 0;
  final int length = 100;
  for (int idx = 0; idx < 100; idx++) {
   bytes[idx] = (byte) (100-idx);
  }
  
  final Buffer instance = new Buffer();
  
  instance.append(bytes, offset, length);
  
  assertEquals("Buffer size mismatch", 100, instance.getCount());
  
  for (int idx = 0; idx < 100; idx++) {
   assertEquals("Buffer contents corrupted", 100-idx, instance.get()[idx]);
  }
  
 }
}

内容来源于网络，如有侵权，请联系作者删除！

Buffer

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com