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

ZipNumBlockLoader介绍

暂无

代码示例

代码示例来源：origin: org.netpreserve.commons/webarchive-commons

SeekableLineReader doBlockLoad(String partId, long startOffset, int totalLength) {
  String path = getReaderPath(partId);
  return blockLoader.attemptLoadBlock(path, startOffset, totalLength, true, this.isRequired());
}

代码示例来源：origin: org.netpreserve.commons/webarchive-commons

private void closeExistingFiles(ArrayList<String[]> filesToClose) {
  for (String[] files : filesToClose) {
    for (String file : files) {
      try {
        blockLoader.closeFileFactory(file);
      } catch (IOException e) {
        LOGGER.warning(e.toString());
      }
    }
  }
}

代码示例来源：origin: iipc/webarchive-commons

public SeekableLineReader createBlockReader(String uri) throws IOException
{
  SeekableLineReader reader = null;
  
  if (GeneralURIStreamFactory.isHttp(uri)) {
    reader = getHttpReader(uri);
  } else {
    reader = getFileReader(uri);
  }
  
  slrMap.get().put(uri, reader);
      
  return reader;
}

代码示例来源：origin: iipc/webarchive-commons

public CloseableIterator<String> getCDXIterator(String key, String start, boolean exact, ZipNumParams params) throws IOException {
  
  CloseableIterator<String> summaryIter = summary.getRecordIteratorLT(key);
  
  if (params.getTimestampDedupLength() > 0) {
    summaryIter = new TimestampDedupIterator(summaryIter, params.getTimestampDedupLength());
  }
  
  summaryIter = wrapPrefix(summaryIter, start, exact);
  
  if (blockLoader.isBufferFully() && (params != null) && (params.getMaxBlocks() > 0)) {
    LineBufferingIterator lineBufferIter = new LineBufferingIterator(summaryIter, params.getMaxBlocks(), params.isReverse());
    lineBufferIter.bufferInput();
    summaryIter = lineBufferIter;
  }
  
  return wrapStartIterator(getCDXIterator(summaryIter, params), start);
}

代码示例来源：origin: org.netpreserve.commons/webarchive-commons

public void init() throws IOException {
  
  if (summaryFile != null) {
    this.summary = new SortedTextFile(GeneralURIStreamFactory.createSeekableStreamFactory(summaryFile, readaheadSize, useNio));
    this.summary.setBinsearchBlockSize(binsearchBlockSize);
  }
          
  if (blockLoader == null) {
    this.blockLoader = new ZipNumBlockLoader();
  }
}

代码示例来源：origin: iipc/webarchive-commons

currReader = createBlockReader(location);

代码示例来源：origin: iipc/openwayback

@Override
  public void shutdown() throws IOException {
    blockLoader.close();
  }
}

代码示例来源：origin: iipc/openwayback

} finally {
  ZipNumBlockLoader.closeAllReaders();

代码示例来源：origin: org.netpreserve.commons/webarchive-commons

public CloseableIterator<String> getCDXIterator(String key, String start, boolean exact, ZipNumParams params) throws IOException {
  
  CloseableIterator<String> summaryIter = summary.getRecordIteratorLT(key);
  
  if (params.getTimestampDedupLength() > 0) {
    summaryIter = new TimestampDedupIterator(summaryIter, params.getTimestampDedupLength());
  }
  
  summaryIter = wrapPrefix(summaryIter, start, exact);
  
  if (blockLoader.isBufferFully() && (params != null) && (params.getMaxBlocks() > 0)) {
    LineBufferingIterator lineBufferIter = new LineBufferingIterator(summaryIter, params.getMaxBlocks(), params.isReverse());
    lineBufferIter.bufferInput();
    summaryIter = lineBufferIter;
  }
  
  return wrapStartIterator(getCDXIterator(summaryIter, params), start);
}

代码示例来源：origin: org.netpreserve.commons/commons-web

public void init() throws IOException {
  
  if (summaryFile != null) {
    this.summary = new SortedTextFile(GeneralURIStreamFactory.createSeekableStreamFactory(summaryFile, readaheadSize, useNio));
    this.summary.setBinsearchBlockSize(binsearchBlockSize);
  }
          
  if (blockLoader == null) {
    this.blockLoader = new ZipNumBlockLoader();
  }
}

代码示例来源：origin: org.netpreserve.commons/commons-web

currReader = createBlockReader(location);

代码示例来源：origin: org.netpreserve.openwayback/openwayback-core

@Override
  public void shutdown() throws IOException {
    blockLoader.close();
  }
}

代码示例来源：origin: org.netpreserve.openwayback/openwayback-core

} finally {
  ZipNumBlockLoader.closeAllReaders();

代码示例来源：origin: org.netpreserve.commons/commons-web

SeekableLineReader doBlockLoad(String partId, long startOffset, int totalLength) {
  String path = getReaderPath(partId);
  return blockLoader.attemptLoadBlock(path, startOffset, totalLength, true, this.isRequired());
}

代码示例来源：origin: org.netpreserve.commons/commons-web

public SeekableLineReader createBlockReader(String uri) throws IOException
{
  SeekableLineReader reader = null;
  
  if (GeneralURIStreamFactory.isHttp(uri)) {
    reader = getHttpReader(uri);
  } else {
    reader = getFileReader(uri);
  }
  
  slrMap.get().put(uri, reader);
      
  return reader;
}

代码示例来源：origin: org.netpreserve.commons/commons-web

public CloseableIterator<String> getCDXIterator(String key, String start, boolean exact, ZipNumParams params) throws IOException {
  
  CloseableIterator<String> summaryIter = summary.getRecordIteratorLT(key);
  
  if (params.getTimestampDedupLength() > 0) {
    summaryIter = new TimestampDedupIterator(summaryIter, params.getTimestampDedupLength());
  }
  
  summaryIter = wrapPrefix(summaryIter, start, exact);
  
  if (blockLoader.isBufferFully() && (params != null) && (params.getMaxBlocks() > 0)) {
    LineBufferingIterator lineBufferIter = new LineBufferingIterator(summaryIter, params.getMaxBlocks(), params.isReverse());
    lineBufferIter.bufferInput();
    summaryIter = lineBufferIter;
  }
  
  return wrapStartIterator(getCDXIterator(summaryIter, params), start);
}

代码示例来源：origin: org.netpreserve.commons/commons-web

private void closeExistingFiles(ArrayList<String[]> filesToClose) {
  for (String[] files : filesToClose) {
    for (String file : files) {
      try {
        blockLoader.closeFileFactory(file);
      } catch (IOException e) {
        LOGGER.warning(e.toString());
      }
    }
  }
}

代码示例来源：origin: iipc/webarchive-commons

public void init() throws IOException {
  
  if (summaryFile != null) {
    this.summary = new SortedTextFile(GeneralURIStreamFactory.createSeekableStreamFactory(summaryFile, readaheadSize, useNio));
    this.summary.setBinsearchBlockSize(binsearchBlockSize);
  }
          
  if (blockLoader == null) {
    this.blockLoader = new ZipNumBlockLoader();
  }
}

代码示例来源：origin: org.netpreserve.commons/webarchive-commons

currReader = createBlockReader(location);

代码示例来源：origin: iipc/webarchive-commons

SeekableLineReader doBlockLoad(String partId, long startOffset, int totalLength) {
  String path = getReaderPath(partId);
  return blockLoader.attemptLoadBlock(path, startOffset, totalLength, true, this.isRequired());
}