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

Buffer.getCount介绍

[英]Get the current count of the buffer.
[中]获取缓冲区的当前计数。

代码示例

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

/**
 * Convert the byte buffer to a string an specific character encoding
 *
 * @param charsetName Valid Java Character Set Name
 */
public String toString(String charsetName)
 throws UnsupportedEncodingException {
 return new String(this.get(), 0, this.getCount(), charsetName);
}

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

/**
 * Convert the byte buffer to a string an specific character encoding
 *
 * @param charsetName Valid Java Character Set Name
 */
public String toString(String charsetName)
 throws UnsupportedEncodingException {
 return new String(this.get(), 0, this.getCount(), charsetName);
}

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

/**
 * Convert the byte buffer to a string an specific character encoding
 *
 * @param charsetName Valid Java Character Set Name
 */
public String toString(String charsetName)
 throws UnsupportedEncodingException {
 return new String(this.get(), 0, this.getCount(), charsetName);
}

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

/**
 * Convert the byte buffer to a string an specific character encoding
 *
 * @param charsetName Valid Java Character Set Name
 */
public String toString(String charsetName)
 throws UnsupportedEncodingException {
 return new String(this.get(), 0, this.getCount(), charsetName);
}

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

/**
 * Convert the byte buffer to a string an specific character encoding
 *
 * @param charsetName Valid Java Character Set Name
 */
public String toString(String charsetName)
 throws UnsupportedEncodingException {
 return new String(this.get(), 0, this.getCount(), charsetName);
}

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

@Override
 public Object clone() throws CloneNotSupportedException {
  Buffer result = (Buffer) super.clone();
  result.copy(this.get(), 0, this.getCount());
  return result;
 }
}

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

@Override
public void writeBuffer(Buffer buf, String tag)
 throws IOException {
 byte[] barr = buf.get();
 int len = buf.getCount();
 Utils.writeVInt(out, len);
 out.write(barr, 0, len);
}

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

@Override
 public Object clone() throws CloneNotSupportedException {
  Buffer result = (Buffer) super.clone();
  result.copy(this.get(), 0, this.getCount());
  return result;
 }
}

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

public void writeBuffer(Buffer buf, String tag)
 throws IOException {
 byte[] barr = buf.get();
 int len = buf.getCount();
 Utils.writeVInt(out, len);
 out.write(barr, 0, len);
}

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

public void writeBuffer(Buffer buf, String tag)
 throws IOException {
 byte[] barr = buf.get();
 int len = buf.getCount();
 Utils.writeVInt(out, len);
 out.write(barr, 0, len);
}

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

@Override
 public Object clone() throws CloneNotSupportedException {
  Buffer result = (Buffer) super.clone();
  result.copy(this.get(), 0, this.getCount());
  return result;
 }
}

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

public Object clone() throws CloneNotSupportedException {
  Buffer result = (Buffer) super.clone();
  result.copy(this.get(), 0, this.getCount());
  return result;
 }
}

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

@Override
public void writeBuffer(Buffer buf, String tag)
 throws IOException {
 byte[] barr = buf.get();
 int len = buf.getCount();
 Utils.writeVInt(out, len);
 out.write(barr, 0, len);
}

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

public Object clone() throws CloneNotSupportedException {
  Buffer result = (Buffer) super.clone();
  result.copy(this.get(), 0, this.getCount());
  return result;
 }
}

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

@Override
public void writeBuffer(Buffer buf, String tag)
 throws IOException {
 byte[] barr = buf.get();
 int len = buf.getCount();
 Utils.writeVInt(out, len);
 out.write(barr, 0, len);
}

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

@Override
 public Object clone() throws CloneNotSupportedException {
  Buffer result = (Buffer) super.clone();
  result.copy(this.get(), 0, this.getCount());
  return result;
 }
}

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

@Override
public void writeBuffer(Buffer buf, String tag)
 throws IOException {
 byte[] barr = buf.get();
 int len = buf.getCount();
 Utils.writeVInt(out, len);
 out.write(barr, 0, len);
}

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

@Override
public void writeBuffer(Buffer buf, String tag)
 throws IOException {
 byte[] barr = buf.get();
 int len = buf.getCount();
 Utils.writeVInt(out, len);
 out.write(barr, 0, len);
}

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

/**
 * Writes a bytes buffer as a typed bytes sequence.
 * 
 * @param buffer the bytes buffer to be written
 * @throws IOException
 */
public void writeBytes(Buffer buffer) throws IOException {
 writeBytes(buffer.get(), Type.BYTES.code, buffer.getCount());
}

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

/**
 * Writes a bytes buffer as a typed bytes sequence.
 * 
 * @param buffer the bytes buffer to be written
 * @throws IOException
 */
public void writeBytes(Buffer buffer) throws IOException {
 writeBytes(buffer.get(), Type.BYTES.code, buffer.getCount());
}