co.cask.cdap.api.common.Bytes.getBytes()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(2.9k)|赞(0)|评价(0)|浏览(108)

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

Bytes.getBytes介绍

[英]This method will get a sequence of bytes from pos -> limit, but will restore pos after.
[中]此方法将从pos->limit获取一个字节序列,但将在之后恢复pos。

代码示例

代码示例来源:origin: cdapio/cdap

@Override
 public Encoder writeBytes(ByteBuffer bytes) throws IOException {
  writeBytes(Bytes.getBytes(bytes));
  return this;
 }
}

代码示例来源:origin: co.cask.cdap/cdap-spark-core2

@Override
 public Encoder writeBytes(ByteBuffer bytes) throws IOException {
  writeBytes(Bytes.getBytes(bytes));
  return this;
 }
}

代码示例来源:origin: caskdata/cdap

@Override
 public Encoder writeBytes(ByteBuffer bytes) throws IOException {
  writeBytes(Bytes.getBytes(bytes));
  return this;
 }
}

代码示例来源:origin: caskdata/cdap

private void encodeBytes(Encoder encoder, ByteBuffer buffer) throws IOException {
 if (buffer.hasArray()) {
  encoder.writeBytes(buffer.array(), buffer.arrayOffset() + buffer.position(), buffer.remaining());
 } else {
  byte[] buf = Bytes.getBytes(buffer);
  buffer.mark();
  buffer.get(buf);
  buffer.reset();
  encoder.writeBytes(buf, 0, buf.length);
 }
}

代码示例来源:origin: co.cask.wrangler/wrangler-core

private static void writeBytes(JsonWriter writer, ByteBuffer buffer) throws IOException {
 if (buffer.hasArray()) {
  writeBytes(writer, buffer.array(), buffer.arrayOffset() + buffer.position(), buffer.remaining());
 } else {
  byte[] buf = Bytes.getBytes(buffer);
  buffer.mark();
  buffer.get(buf);
  buffer.reset();
  writeBytes(writer, buf, 0, buf.length);
 }
}

代码示例来源:origin: co.cask.cdap/cdap-formats

private void encodeBytes(Encoder encoder, ByteBuffer buffer) throws IOException {
 if (buffer.hasArray()) {
  encoder.writeBytes(buffer.array(), buffer.arrayOffset() + buffer.position(), buffer.remaining());
 } else {
  byte[] buf = Bytes.getBytes(buffer);
  buffer.mark();
  buffer.get(buf);
  buffer.reset();
  encoder.writeBytes(buf, 0, buf.length);
 }
}

代码示例来源:origin: co.cask.cdap/cdap-etl-common

private static void writeBytes(JsonWriter writer, ByteBuffer buffer) throws IOException {
 if (buffer.hasArray()) {
  writeBytes(writer, buffer.array(), buffer.arrayOffset() + buffer.position(), buffer.remaining());
 } else {
  byte[] buf = Bytes.getBytes(buffer);
  buffer.mark();
  buffer.get(buf);
  buffer.reset();
  writeBytes(writer, buf, 0, buf.length);
 }
}

代码示例来源:origin: caskdata/cdap

@Override
 public Encoder writeBytes(ByteBuffer bytes) throws IOException {
  if (bytes.hasArray()) {
   writeBytes(bytes.array(), bytes.arrayOffset() + bytes.position(), bytes.remaining());
  } else {
   byte[] buf = Bytes.getBytes(bytes);
   bytes.mark();
   bytes.get(buf);
   bytes.reset();
   writeBytes(buf, 0, buf.length);
  }
  return this;
 }
}

代码示例来源:origin: co.cask.cdap/cdap-formats

@Override
 public Encoder writeBytes(ByteBuffer bytes) throws IOException {
  if (bytes.hasArray()) {
   writeBytes(bytes.array(), bytes.arrayOffset() + bytes.position(), bytes.remaining());
  } else {
   byte[] buf = Bytes.getBytes(bytes);
   bytes.mark();
   bytes.get(buf);
   bytes.reset();
   writeBytes(buf, 0, buf.length);
  }
  return this;
 }
}

相关文章