本文整理了Java中co.cask.cdap.api.common.Bytes.getBytes()
方法的一些代码示例,展示了Bytes.getBytes()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Bytes.getBytes()
方法的具体详情如下:
包路径:co.cask.cdap.api.common.Bytes
类名称: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;
}
}
内容来源于网络,如有侵权,请联系作者删除!