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

Zip.setInput介绍

暂无

代码示例

代码示例来源：origin: bluestreak01/questdb

private void prepareCompressedBody() {
  if (z_streamp == 0) {
    z_streamp = Zip.deflateInit();
    zout = ByteBuffer.allocateDirect(sz);
    pzout = ByteBuffers.getAddress(zout);
  }
  int r = (int) (_wPtr - outPtr);
  Zip.setInput(z_streamp, outPtr, r);
  this.crc = Zip.crc32(this.crc, outPtr, r);
  this.total += r;
  _wPtr = outPtr;
}

代码示例来源：origin: bluestreak01/questdb

private void prepareCompressedBody() {
  if (z_streamp == 0) {
    z_streamp = Zip.deflateInit();
    zout = ByteBuffer.allocateDirect(sz);
    pzout = ByteBuffers.getAddress(zout);
  }
  int r = (int) (_wPtr - outPtr);
  Zip.setInput(z_streamp, outPtr, r);
  this.crc = Zip.crc32(this.crc, outPtr, r);
  this.total += r;
  _wPtr = outPtr;
}

代码示例来源：origin: bluestreak01/questdb

@Override
public int write(ByteBuffer src) throws IOException {
  if (!ByteBuffers.isDirect(src)) {
    throw new IllegalArgumentException("Heap buffers are not supported");
  }
  int result = src.remaining();
  int pos = src.position();
  Zip.setInput(z_streamp, ByteBuffers.getAddress(src) + pos, result);
  crc = Zip.crc32(crc, ByteBuffers.getAddress(src) + pos, result);
  deflate(false);
  src.position(pos + result);
  total += result;
  return result;
}

代码示例来源：origin: bluestreak01/questdb

@Override
public int write(ByteBuffer src) throws IOException {
  if (!ByteBuffers.isDirect(src)) {
    throw new IllegalArgumentException("Heap buffers are not supported");
  }
  int result = src.remaining();
  int pos = src.position();
  Zip.setInput(z_streamp, ByteBuffers.getAddress(src) + pos, result);
  crc = Zip.crc32(crc, ByteBuffers.getAddress(src) + pos, result);
  deflate(false);
  src.position(pos + result);
  total += result;
  return result;
}

代码示例来源：origin: bluestreak01/questdb

while ((len = (int) Files.read(fdIn, in, available, pIn)) > 0) {
  pIn += len;
  Zip.setInput(strm, in, len);
  crc = Zip.crc32(crc, in, len);
  do {