本文整理了Java中com.couchbase.client.deps.io.netty.buffer.ByteBuf.getBytes()
方法的一些代码示例,展示了ByteBuf.getBytes()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ByteBuf.getBytes()
方法的具体详情如下:
包路径:com.couchbase.client.deps.io.netty.buffer.ByteBuf
类名称:ByteBuf
方法名:getBytes
[英]Transfers this buffer's data to the specified destination starting at the specified absolute index until the destination becomes non-writable. This method is basically same with #getBytes(int,ByteBuf,int,int), except that this method increases the writerIndex of the destination by the number of the transferred bytes while #getBytes(int,ByteBuf,int,int) does not. This method does not modify readerIndex or writerIndex of the source buffer (i.e. this).
[中]从指定的绝对索引开始将此缓冲区的数据传输到指定的目标,直到目标变为不可写。此方法与#getBytes(int,ByteBuf,int,int)基本相同,只是此方法将目标的writerIndex增加传输的字节数,而#getBytes(int,ByteBuf,int,int)不增加。此方法不会修改源缓冲区的readerIndex或writerIndex(即此)。
代码示例来源:origin: apache/incubator-gobblin
void verify(Bucket bucket)
throws UnsupportedEncodingException {
// verify
System.out.println("Starting verification procedure");
for (Map.Entry<String, byte[]> cacheEntry : verificationCache.entrySet()) {
Object doc = bucket.get(cacheEntry.getKey(), recordClass);
if (doc instanceof TupleDocument) {
ByteBuf returnedBuf = (((TupleDocument) doc).content()).value1();
byte[] returnedBytes = new byte[returnedBuf.readableBytes()];
returnedBuf.getBytes(0, returnedBytes);
Assert.assertEquals(returnedBytes, cacheEntry.getValue(), "Returned content for TupleDoc should be equal");
} else if (doc instanceof RawJsonDocument) {
byte[] returnedBytes = ((RawJsonDocument) doc).content().getBytes("UTF-8");
Assert.assertEquals(returnedBytes, cacheEntry.getValue(), "Returned content for JsonDoc should be equal");
} else {
Assert.fail("Returned type was neither TupleDocument nor RawJsonDocument");
}
}
System.out.println("Verification success!");
}
}
代码示例来源:origin: apache/incubator-gobblin
void onWrite(AbstractDocument doc)
throws UnsupportedEncodingException {
recordClass = doc.getClass();
if (doc instanceof TupleDocument) {
ByteBuf outgoingBuf = (((TupleDocument) doc).content()).value1();
byte[] outgoingBytes = new byte[outgoingBuf.readableBytes()];
outgoingBuf.getBytes(0, outgoingBytes);
verificationCache.put(doc.id(), outgoingBytes);
} else if (doc instanceof RawJsonDocument) {
verificationCache.put(doc.id(), ((RawJsonDocument) doc).content().getBytes("UTF-8"));
} else {
throw new UnsupportedOperationException("Can only support TupleDocument or RawJsonDocument at this time");
}
}
代码示例来源:origin: apache/nifi
byteBuf.getBytes(byteBuf.readerIndex(), out, byteBuf.readableBytes());
byteBuf.release();
};
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, byte[] dst) {
buf.getBytes(index, dst);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, ByteBuffer dst) {
buf.getBytes(index, dst);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, ByteBuf dst, int dstIndex, int length) {
buf.getBytes(index, dst, dstIndex, length);
return this;
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
public ByteBuf getBytes(int index, ByteBuf dst, int length) {
buf.getBytes(index, dst, length);
return this;
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
public ByteBuf getBytes(int index, byte[] dst) {
buf.getBytes(index, dst);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, ByteBuf dst, int dstIndex, int length) {
unwrap().getBytes(index, dst, dstIndex, length);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, ByteBuffer dst) {
unwrap().getBytes(index, dst);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, byte[] dst, int dstIndex, int length) {
unwrap().getBytes(index, dst, dstIndex, length);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, OutputStream out, int length)
throws IOException {
unwrap().getBytes(index, out, length);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public int getBytes(int index, GatheringByteChannel out, int length)
throws IOException {
return unwrap().getBytes(index, out, length);
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, OutputStream out, int length)
throws IOException {
unwrap().getBytes(index, out, length);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, byte[] dst, int dstIndex, int length) {
checkIndex(index, length);
buffer.getBytes(index, dst, dstIndex, length);
return this;
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
public ByteBuf getBytes(int index, OutputStream out, int length)
throws IOException {
unwrap().getBytes(index, out, length);
return this;
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
public ByteBuf getBytes(int index, ByteBuf dst, int dstIndex, int length) {
unwrap().getBytes(index, dst, dstIndex, length);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, ByteBuffer dst) {
checkIndex0(index, dst.remaining());
unwrap().getBytes(idx(index), dst);
return this;
}
代码示例来源:origin: com.couchbase.client/core-io
@Override
public ByteBuf getBytes(int index, ByteBuf dst, int dstIndex, int length) {
checkIndex0(index, length);
unwrap().getBytes(idx(index), dst, dstIndex, length);
return this;
}
代码示例来源:origin: couchbase/couchbase-jvm-core
@Override
public ByteBuf getBytes(int index, ByteBuf dst, int dstIndex, int length) {
checkIndex0(index, length);
unwrap().getBytes(idx(index), dst, dstIndex, length);
return this;
}
内容来源于网络,如有侵权,请联系作者删除!