本文整理了Java中org.archive.format.gzip.zipnum.ZipNumIndex.wrapEndIterator()
方法的一些代码示例,展示了ZipNumIndex.wrapEndIterator()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZipNumIndex.wrapEndIterator()
方法的具体详情如下:
包路径:org.archive.format.gzip.zipnum.ZipNumIndex
类名称:ZipNumIndex
方法名:wrapEndIterator
暂无
代码示例来源:origin: org.netpreserve.commons/commons-web
public static CloseableIterator<String> wrapPrefix(CloseableIterator<String> source, String prefix, boolean exact)
{
if (exact) {
return wrapEndIterator(source, endKey(prefix), false);
} else {
return wrapEndIterator(source, prefix, true);
}
}
代码示例来源:origin: org.netpreserve.commons/webarchive-commons
public static CloseableIterator<String> wrapPrefix(CloseableIterator<String> source, String prefix, boolean exact)
{
if (exact) {
return wrapEndIterator(source, endKey(prefix), false);
} else {
return wrapEndIterator(source, prefix, true);
}
}
代码示例来源:origin: iipc/webarchive-commons
public static CloseableIterator<String> wrapPrefix(CloseableIterator<String> source, String prefix, boolean exact)
{
if (exact) {
return wrapEndIterator(source, endKey(prefix), false);
} else {
return wrapEndIterator(source, prefix, true);
}
}
代码示例来源:origin: org.netpreserve.commons/commons-web
public CloseableIterator<String> getClusterRange(String start, String end, boolean inclusive, boolean includePrevLine) throws IOException
{
CloseableIterator<String> iter = null;
iter = summary.getRecordIterator(start, includePrevLine);
return wrapEndIterator(iter, end, inclusive);
//return wrapStartEndIterator(iter, start, end, inclusive);
}
代码示例来源:origin: org.netpreserve.commons/webarchive-commons
public CloseableIterator<String> getClusterRange(String start, String end, boolean inclusive, boolean includePrevLine) throws IOException
{
CloseableIterator<String> iter = null;
iter = summary.getRecordIterator(start, includePrevLine);
return wrapEndIterator(iter, end, inclusive);
//return wrapStartEndIterator(iter, start, end, inclusive);
}
代码示例来源:origin: iipc/webarchive-commons
public CloseableIterator<String> getClusterRange(String start, String end, boolean inclusive, boolean includePrevLine) throws IOException
{
CloseableIterator<String> iter = null;
iter = summary.getRecordIterator(start, includePrevLine);
return wrapEndIterator(iter, end, inclusive);
//return wrapStartEndIterator(iter, start, end, inclusive);
}
代码示例来源:origin: org.netpreserve.commons/webarchive-commons
public static CloseableIterator<String> wrapStartEndIterator(CloseableIterator<String> iter, String start, String end, boolean inclusive)
{
return wrapEndIterator(wrapStartIterator(iter, start), end, inclusive);
}
代码示例来源:origin: org.netpreserve.commons/commons-web
public static CloseableIterator<String> wrapStartEndIterator(CloseableIterator<String> iter, String start, String end, boolean inclusive)
{
return wrapEndIterator(wrapStartIterator(iter, start), end, inclusive);
}
代码示例来源:origin: iipc/webarchive-commons
public static CloseableIterator<String> wrapStartEndIterator(CloseableIterator<String> iter, String start, String end, boolean inclusive)
{
return wrapEndIterator(wrapStartIterator(iter, start), end, inclusive);
}
代码示例来源:origin: org.netpreserve.commons/webarchive-commons
public CloseableIterator<String> getCDXIterator(CloseableIterator<String> summaryIterator, String start, String end, int split, int numSplits, ZipNumParams params)
{
CloseableIterator<String> blocklines = this.getCDXIterator(summaryIterator, params);
if ((split == 0) && (start != null) && !start.isEmpty()) {
blocklines = wrapStartIterator(blocklines, start);
}
if ((split >= (numSplits - 1)) && (end != null) && !end.isEmpty()) {
blocklines = wrapEndIterator(blocklines, end, false);
}
return blocklines;
}
代码示例来源:origin: org.netpreserve.commons/commons-web
public CloseableIterator<String> getCDXIterator(CloseableIterator<String> summaryIterator, String start, String end, int split, int numSplits, ZipNumParams params)
{
CloseableIterator<String> blocklines = this.getCDXIterator(summaryIterator, params);
if ((split == 0) && (start != null) && !start.isEmpty()) {
blocklines = wrapStartIterator(blocklines, start);
}
if ((split >= (numSplits - 1)) && (end != null) && !end.isEmpty()) {
blocklines = wrapEndIterator(blocklines, end, false);
}
return blocklines;
}
代码示例来源:origin: iipc/webarchive-commons
public CloseableIterator<String> getCDXIterator(CloseableIterator<String> summaryIterator, String start, String end, int split, int numSplits, ZipNumParams params)
{
CloseableIterator<String> blocklines = this.getCDXIterator(summaryIterator, params);
if ((split == 0) && (start != null) && !start.isEmpty()) {
blocklines = wrapStartIterator(blocklines, start);
}
if ((split >= (numSplits - 1)) && (end != null) && !end.isEmpty()) {
blocklines = wrapEndIterator(blocklines, end, false);
}
return blocklines;
}
代码示例来源:origin: org.netpreserve.commons/webarchive-commons
public CloseableIterator<String> getCDXIterator(String key, String start, String end, ZipNumParams params) throws IOException {
if (start.equals(key)) {
return ZipNumIndex.wrapEndIterator(getRecordIterator(key), end, false);
} else {
return ZipNumIndex.wrapStartEndIterator(getRecordIterator(key), start, end, false);
}
}
代码示例来源:origin: org.netpreserve.commons/commons-web
public CloseableIterator<String> getCDXIterator(String key, String start, String end, ZipNumParams params) throws IOException {
if (start.equals(key)) {
return ZipNumIndex.wrapEndIterator(getRecordIterator(key), end, false);
} else {
return ZipNumIndex.wrapStartEndIterator(getRecordIterator(key), start, end, false);
}
}
代码示例来源:origin: iipc/webarchive-commons
public CloseableIterator<String> getCDXIterator(String key, String start, String end, ZipNumParams params) throws IOException {
if (start.equals(key)) {
return ZipNumIndex.wrapEndIterator(getRecordIterator(key), end, false);
} else {
return ZipNumIndex.wrapStartEndIterator(getRecordIterator(key), start, end, false);
}
}
代码示例来源:origin: org.netpreserve.commons/commons-web
public CloseableIterator<String> getCDXIterator(String key, String start, String end, ZipNumParams params) throws IOException {
CloseableIterator<String> summaryIter = summary.getRecordIteratorLT(key);
if (params.getTimestampDedupLength() > 0) {
summaryIter = new TimestampDedupIterator(summaryIter, params.getTimestampDedupLength());
}
if (end != null && !end.isEmpty()) {
summaryIter = wrapEndIterator(summaryIter, end, false);
}
if (blockLoader.isBufferFully() && (params != null) && (params.getMaxBlocks() > 0)) {
LineBufferingIterator lineBufferIter = new LineBufferingIterator(summaryIter, params.getMaxBlocks(), params.isReverse());
lineBufferIter.bufferInput();
summaryIter = lineBufferIter;
}
if (params.isReverse()) {
return wrapReverseIterator(getCDXIterator(summaryIter, params), start, endKey(key));
} else {
return wrapStartEndIterator(getCDXIterator(summaryIter, params), start, end, false);
}
}
代码示例来源:origin: iipc/webarchive-commons
public CloseableIterator<String> getCDXIterator(String key, String start, String end, ZipNumParams params) throws IOException {
CloseableIterator<String> summaryIter = summary.getRecordIteratorLT(key);
if (params.getTimestampDedupLength() > 0) {
summaryIter = new TimestampDedupIterator(summaryIter, params.getTimestampDedupLength());
}
if (end != null && !end.isEmpty()) {
summaryIter = wrapEndIterator(summaryIter, end, false);
}
if (blockLoader.isBufferFully() && (params != null) && (params.getMaxBlocks() > 0)) {
LineBufferingIterator lineBufferIter = new LineBufferingIterator(summaryIter, params.getMaxBlocks(), params.isReverse());
lineBufferIter.bufferInput();
summaryIter = lineBufferIter;
}
if (params.isReverse()) {
return wrapReverseIterator(getCDXIterator(summaryIter, params), start, endKey(key));
} else {
return wrapStartEndIterator(getCDXIterator(summaryIter, params), start, end, false);
}
}
代码示例来源:origin: org.netpreserve.commons/webarchive-commons
public CloseableIterator<String> getCDXIterator(String key, String start, String end, ZipNumParams params) throws IOException {
CloseableIterator<String> summaryIter = summary.getRecordIteratorLT(key);
if (params.getTimestampDedupLength() > 0) {
summaryIter = new TimestampDedupIterator(summaryIter, params.getTimestampDedupLength());
}
if (end != null && !end.isEmpty()) {
summaryIter = wrapEndIterator(summaryIter, end, false);
}
if (blockLoader.isBufferFully() && (params != null) && (params.getMaxBlocks() > 0)) {
LineBufferingIterator lineBufferIter = new LineBufferingIterator(summaryIter, params.getMaxBlocks(), params.isReverse());
lineBufferIter.bufferInput();
summaryIter = lineBufferIter;
}
if (params.isReverse()) {
return wrapReverseIterator(getCDXIterator(summaryIter, params), start, endKey(key));
} else {
return wrapStartEndIterator(getCDXIterator(summaryIter, params), start, end, false);
}
}
内容来源于网络,如有侵权,请联系作者删除!