- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.archive.format.gzip.zipnum.ZipNumParams
类的一些代码示例,展示了ZipNumParams
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ZipNumParams
类的具体详情如下:
包路径:org.archive.format.gzip.zipnum.ZipNumParams
类名称:ZipNumParams
暂无
代码示例来源:origin: org.netpreserve.commons/commons-web
public SummaryBlockIterator(CloseableIterator<String> summaryIterator, ZipNumIndex zipnumIndex, ZipNumParams params)
{
this.zipnumIndex = zipnumIndex;
this.summaryIterator = summaryIterator;
this.isFirst = true;
if (params != null) {
this.params = params;
} else {
this.params = new ZipNumParams();
}
}
代码示例来源:origin: iipc/openwayback
public void init() throws IOException
{
//this.cluster = new ZipNumCluster(clusterUri, summaryFile, blockLoader);
oneBlockParams = new ZipNumParams();
oneBlockParams.setMaxBlocks(1);
}
代码示例来源: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: iipc/openwayback
String searchKey = null;
ZipNumParams params = new ZipNumParams(defaultParams);
params.setSequential(true);
params.setReverse(query.isReverse());
String endkey = (query.closest.isEmpty() ? "!" : " "
+ query.closest);
params.setMaxAggregateBlocks(1);
searchKey = startEndUrl[0] + endkey;
} else {
params.setTimestampDedupLength(0);
return zipnumSource.getCDXIterator(idx, searchKey, startEndUrl[1],
query.page, pageResult.numPages, params);
代码示例来源:origin: org.netpreserve.commons/webarchive-commons
if ((params.getMaxBlocks() > 0) && (totalBlocks >= params.getMaxBlocks())) {
return null;
int maxAggregateBlocks = params.getMaxAggregateBlocks();
((params.getMaxBlocks() <= 0) || (totalBlocks + numBlocks) < params.getMaxBlocks())
&& currLine.isContinuous(nextLine));
if (params.isReverse()) {
slrIter = new LineBufferingIterator(slrIter, zipnumIndex.getCdxLinesPerBlock(), true);
代码示例来源:origin: org.netpreserve.commons/commons-web
public CloseableIterator<String> getCDXIterator(String key, String start, String end, ZipNumParams params) throws IOException {
if (params.isSequential()) {
return this.createSeqIterator(key, start, end, params);
}
SortedCompositeIterator<String> scitr = new SortedCompositeIterator<String>(cdx.size(), params.isReverse() ? reverseComparator : comparator);
CloseableIterator<String> iter = null;
for (CDXInputSource cdxReader : cdx) {
try {
iter = cdxReader.getCDXIterator(key, start, end, params);
scitr.addIterator(iter);
} catch (IOException io) {
LOGGER.warning(io.toString());
}
}
return scitr;
}
代码示例来源:origin: org.netpreserve.commons/commons-web
public CloseableIterator<String> getCDXIterator(String key, String prefix, boolean exact, ZipNumParams params) throws IOException {
SortedCompositeIterator<String> scitr = new SortedCompositeIterator<String>(cdx.size(), params.isReverse() ? reverseComparator : comparator);
CloseableIterator<String> iter = null;
for (CDXInputSource cdxReader : cdx) {
try {
iter = cdxReader.getCDXIterator(key, prefix, exact, params);
scitr.addIterator(iter);
} catch (IOException io) {
LOGGER.warning(io.toString());
}
}
return scitr;
}
代码示例来源: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.openwayback/openwayback-cdx-server
String searchKey = null;
ZipNumParams params = new ZipNumParams(defaultParams);
params.setSequential(true);
params.setReverse(query.isReverse());
String endkey = (query.closest.isEmpty() ? "!" : " "
+ query.closest);
params.setMaxAggregateBlocks(1);
searchKey = startEndUrl[0] + endkey;
} else {
params.setTimestampDedupLength(0);
return zipnumSource.getCDXIterator(idx, searchKey, startEndUrl[1],
query.page, pageResult.numPages, params);
代码示例来源:origin: iipc/webarchive-commons
if ((params.getMaxBlocks() > 0) && (totalBlocks >= params.getMaxBlocks())) {
return null;
int maxAggregateBlocks = params.getMaxAggregateBlocks();
((params.getMaxBlocks() <= 0) || (totalBlocks + numBlocks) < params.getMaxBlocks())
&& currLine.isContinuous(nextLine));
if (params.isReverse()) {
slrIter = new LineBufferingIterator(slrIter, zipnumIndex.getCdxLinesPerBlock(), true);
代码示例来源:origin: org.netpreserve.openwayback/openwayback-core
public void init() throws IOException
{
//this.cluster = new ZipNumCluster(clusterUri, summaryFile, blockLoader);
oneBlockParams = new ZipNumParams();
oneBlockParams.setMaxBlocks(1);
}
代码示例来源:origin: org.netpreserve.commons/webarchive-commons
public CloseableIterator<String> getCDXIterator(String key, String start, String end, ZipNumParams params) throws IOException {
if (params.isSequential()) {
return this.createSeqIterator(key, start, end, params);
}
SortedCompositeIterator<String> scitr = new SortedCompositeIterator<String>(cdx.size(), params.isReverse() ? reverseComparator : comparator);
CloseableIterator<String> iter = null;
for (CDXInputSource cdxReader : cdx) {
try {
iter = cdxReader.getCDXIterator(key, start, end, params);
scitr.addIterator(iter);
} catch (IOException io) {
LOGGER.warning(io.toString());
}
}
return scitr;
}
代码示例来源:origin: iipc/webarchive-commons
public CloseableIterator<String> getCDXIterator(String key, String prefix, boolean exact, ZipNumParams params) throws IOException {
SortedCompositeIterator<String> scitr = new SortedCompositeIterator<String>(cdx.size(), params.isReverse() ? reverseComparator : comparator);
CloseableIterator<String> iter = null;
for (CDXInputSource cdxReader : cdx) {
try {
iter = cdxReader.getCDXIterator(key, prefix, exact, params);
scitr.addIterator(iter);
} catch (IOException io) {
LOGGER.warning(io.toString());
}
}
return scitr;
}
代码示例来源: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: iipc/webarchive-commons
public SummaryBlockIterator(CloseableIterator<String> summaryIterator, ZipNumIndex zipnumIndex, ZipNumParams params)
{
this.zipnumIndex = zipnumIndex;
this.summaryIterator = summaryIterator;
this.isFirst = true;
if (params != null) {
this.params = params;
} else {
this.params = new ZipNumParams();
}
}
代码示例来源:origin: org.netpreserve.commons/commons-web
if ((params.getMaxBlocks() > 0) && (totalBlocks >= params.getMaxBlocks())) {
return null;
int maxAggregateBlocks = params.getMaxAggregateBlocks();
((params.getMaxBlocks() <= 0) || (totalBlocks + numBlocks) < params.getMaxBlocks())
&& currLine.isContinuous(nextLine));
if (params.isReverse()) {
slrIter = new LineBufferingIterator(slrIter, zipnumIndex.getCdxLinesPerBlock(), true);
代码示例来源:origin: iipc/webarchive-commons
public CloseableIterator<String> getCDXIterator(String key, String start, String end, ZipNumParams params) throws IOException {
if (params.isSequential()) {
return this.createSeqIterator(key, start, end, params);
}
SortedCompositeIterator<String> scitr = new SortedCompositeIterator<String>(cdx.size(), params.isReverse() ? reverseComparator : comparator);
CloseableIterator<String> iter = null;
for (CDXInputSource cdxReader : cdx) {
try {
iter = cdxReader.getCDXIterator(key, start, end, params);
scitr.addIterator(iter);
} catch (IOException io) {
LOGGER.warning(io.toString());
}
}
return scitr;
}
代码示例来源:origin: org.netpreserve.commons/webarchive-commons
public CloseableIterator<String> getCDXIterator(String key, String prefix, boolean exact, ZipNumParams params) throws IOException {
SortedCompositeIterator<String> scitr = new SortedCompositeIterator<String>(cdx.size(), params.isReverse() ? reverseComparator : comparator);
CloseableIterator<String> iter = null;
for (CDXInputSource cdxReader : cdx) {
try {
iter = cdxReader.getCDXIterator(key, prefix, exact, params);
scitr.addIterator(iter);
} catch (IOException io) {
LOGGER.warning(io.toString());
}
}
return scitr;
}
代码示例来源: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 SummaryBlockIterator(CloseableIterator<String> summaryIterator, ZipNumIndex zipnumIndex, ZipNumParams params)
{
this.zipnumIndex = zipnumIndex;
this.summaryIterator = summaryIterator;
this.isFirst = true;
if (params != null) {
this.params = params;
} else {
this.params = new ZipNumParams();
}
}
本文整理了Java中org.archive.format.gzip.zipnum.ZipNumParams.isSequential()方法的一些代码示例,展示了ZipNumParams.isSequ
本文整理了Java中org.archive.format.gzip.zipnum.ZipNumParams.()方法的一些代码示例,展示了ZipNumParams.()的具体用法。这些代码示例主要来源
本文整理了Java中org.archive.format.gzip.zipnum.ZipNumParams.getMaxAggregateBlocks()方法的一些代码示例,展示了ZipNumPara
本文整理了Java中org.archive.format.gzip.zipnum.ZipNumParams.getMaxBlocks()方法的一些代码示例,展示了ZipNumParams.getMax
本文整理了Java中org.archive.format.gzip.zipnum.ZipNumParams.getTimestampDedupLength()方法的一些代码示例,展示了ZipNumPa
本文整理了Java中org.archive.format.gzip.zipnum.ZipNumParams.isReverse()方法的一些代码示例,展示了ZipNumParams.isReverse
我是一名优秀的程序员,十分优秀!