本文整理了Java中org.apache.jena.query.Query.setOffset
方法的一些代码示例,展示了Query.setOffset
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query.setOffset
方法的具体详情如下:
包路径:org.apache.jena.query.Query
类名称:Query
方法名:setOffset
暂无
代码示例来源:origin: apache/jena
/**
* Set the offset for the results to return.
* Setting the offset to zero (0) or removes the offset.
* @param offset The offset to set.
*/
public void setOffset(int offset) {
query.setOffset(offset < 1 ? Query.NOLIMIT : offset);
}
代码示例来源:origin: org.apache.jena/jena-querybuilder
/**
* Set the offset for the results to return.
* Setting the offset to zero (0) or removes the offset.
* @param offset The offset to set.
*/
public void setOffset(int offset) {
query.setOffset(offset < 1 ? Query.NOLIMIT : offset);
}
代码示例来源:origin: apache/jena
@Override
public void visitOffset(Query query) {
newQuery.setOffset(query.getOffset());
}
代码示例来源:origin: SmartDataAnalytics/jena-sparql-api
@Override
public void visitOffset(Query query) {
newQuery.setOffset(query.getOffset()) ;
}
代码示例来源:origin: SmartDataAnalytics/jena-sparql-api
query.setOffset(Query.NOLIMIT);
} else {
query.setOffset(nextOffset);
代码示例来源:origin: SmartDataAnalytics/jena-sparql-api
public static void applyRange(Query query, Range<Long> range) {
long offset = rangeToOffset(range);
long limit = rangeToLimit(range);
query.setOffset(offset);
query.setLimit(limit);
}
代码示例来源:origin: apache/jena
final public void OffsetClause() throws ParseException {
Token t ;
jj_consume_token(OFFSET);
t = jj_consume_token(INTEGER);
getQuery().setOffset(integerValue(t.image)) ;
}
代码示例来源:origin: apache/jena
final public void OffsetClause() throws ParseException {
Token t ;
jj_consume_token(OFFSET);
t = jj_consume_token(INTEGER);
getQuery().setOffset(integerValue(t.image)) ;
}
代码示例来源:origin: apache/jena
final public void OffsetClause() throws ParseException {
Token t ;
jj_consume_token(OFFSET);
t = jj_consume_token(INTEGER);
getQuery().setOffset(integerValue(t.image)) ;
}
代码示例来源:origin: SmartDataAnalytics/DL-Learner
@Override
public Model extractFragment(OWLClass cls, int maxFragmentDepth) {
startTime = System.currentTimeMillis();
Model fragment = ModelFactory.createDefaultModel();
Query query = buildConstructQuery(cls, maxFragmentDepth);
long pageSize = PaginationUtils.adjustPageSize(qef, 10000);
query.setLimit(pageSize);
int offset = 0;
while(getRemainingRuntime() > 0){
query.setOffset(offset);System.out.println(query);
Model model = qef.createQueryExecution(query).execConstruct();
fragment.add(model);
offset += pageSize;
}
return fragment;
}
代码示例来源:origin: SmartDataAnalytics/jena-sparql-api
@Override
public QueryExecutionCompare createQueryExecution(Query query) {
if(removeSlices) {
query = (Query)query.clone();
query.setLimit(Query.NOLIMIT);
query.setOffset(Query.NOLIMIT);
}
//boolean isOrdered = !query.getOrderBy().isEmpty();
QueryExecution qea = a.createQueryExecution(query);
QueryExecution qeb = b.createQueryExecution(query);
QueryExecutionCompare result = new QueryExecutionCompare(query, qea, qeb, false);
//QueryExecution result = QueryExecutionWrapper.wrap(tmp);
return result;
}
代码示例来源:origin: SmartDataAnalytics/jena-sparql-api
public PaginationQueryIterator createQueryIterator(Long offset, Long limit) {
long o = offset == null ? 0 : offset;
long l = limit == null ? Long.MAX_VALUE : limit;
long queryOffset = proto.getOffset() == Query.NOLIMIT ? 0 : proto.getOffset();
long itemOffset = queryOffset + o;
long queryLimit = proto.getLimit() == Query.NOLIMIT ? Long.MAX_VALUE : proto.getLimit() - o;
long itemLimit = Math.min(queryLimit, l);
itemLimit = itemLimit == Long.MAX_VALUE ? Query.NOLIMIT : itemLimit;
Query clone = proto.cloneQuery();
clone.setOffset(itemOffset);
clone.setLimit(itemLimit);
PaginationQueryIterator result = new PaginationQueryIterator(clone, pageSize);
return result;
}
}
代码示例来源:origin: tarql/tarql
/**
* Sets up a new query execution.
*
* @param source The input CSV file
* @param options Configuration options for the CSV file
* @param query The input query
*/
public TarqlQueryExecution(InputStreamSource source, CSVOptions options, TarqlQuery query) {
if (options == null) {
options = new CSVOptions();
}
if (options.hasColumnNamesInFirstRow() == null) {
// Presence or absence of header row was not specified on command line or FROM clause.
// So we fall back to the convention where OFFSET 1 in the query
// indicates that a header is present. To make that work, we
// set the OFFSET to 0 and tell the parser to gobble up the first
// row for column names.
options = new CSVOptions(options);
Query firstQuery = query.getQueries().get(0);
if (firstQuery.getOffset() == 1) {
options.setColumnNamesInFirstRow(true);
firstQuery.setOffset(0);
}
}
table = new CSVTable(source, options);
tq = query;
}
代码示例来源:origin: SmartDataAnalytics/jena-sparql-api
@Override
public void visit(OpSlice opSlice)
{
if ( opSlice.getStart() != Query.NOLIMIT )
query.setOffset(opSlice.getStart()) ;
if ( opSlice.getLength() != Query.NOLIMIT )
query.setLimit(opSlice.getLength()) ;
opSlice.getSubOp().visit(this) ;
}
代码示例来源:origin: apache/jena
/**
* Copy all the modifications from the Solution Modifier argument
* @param solutionModifier The solution modifier to copy from.
*/
public void addAll(SolutionModifierHandler solutionModifier) {
List<SortCondition> lst = solutionModifier.query.getOrderBy();
if (lst != null) {
for (SortCondition sc : lst) {
query.addOrderBy(sc);
}
}
query.getGroupBy().addAll(solutionModifier.query.getGroupBy());
query.getHavingExprs().addAll(solutionModifier.query.getHavingExprs());
query.setLimit(solutionModifier.query.getLimit());
query.setOffset(solutionModifier.query.getOffset());
}
代码示例来源:origin: org.apache.jena/jena-querybuilder
/**
* Copy all the modifications from the Solution Modifier argument
* @param solutionModifier The solution modifier to copy from.
*/
public void addAll(SolutionModifierHandler solutionModifier) {
List<SortCondition> lst = solutionModifier.query.getOrderBy();
if (lst != null) {
for (SortCondition sc : lst) {
query.addOrderBy(sc);
}
}
query.getGroupBy().addAll(solutionModifier.query.getGroupBy());
query.getHavingExprs().addAll(solutionModifier.query.getHavingExprs());
query.setLimit(solutionModifier.query.getLimit());
query.setOffset(solutionModifier.query.getOffset());
}
代码示例来源:origin: SmartDataAnalytics/jena-sparql-api
@Override
public QueryExecution createQueryExecution(Query query) {
Query q = query.cloneQuery();
long offset = q.getOffset() == Query.NOLIMIT ? 0 : q.getOffset();
long limit = q.getLimit();
long o = (offset / pageExpandSize) * pageExpandSize;
long l;
if(limit != Query.NOLIMIT) {
long target = offset + limit;
long t = ((target / pageExpandSize) + 1) * pageExpandSize;
l = t - o;
} else {
l = Query.NOLIMIT;
}
long start = o - offset;
// Align offset and target to pageExpandSize boundaries
q.setOffset(o);
q.setLimit(l);
QueryExecution qe = qef.createQueryExecution(q);
//QueryExecutionRange result = new QueryExecutionRange(qe, start, l);
QueryExecution result = null;
return result;
}
代码示例来源:origin: SmartDataAnalytics/DL-Learner
query.setOffset(i++ * pageSize);
QueryExecution qe = ksQef.createQueryExecution(query);
Model tmp = qe.execConstruct();
代码示例来源:origin: SmartDataAnalytics/jena-sparql-api
public static Query createQueryList(UnaryRelation concept, Long limit, Long offset) {
Query result = new Query();
result.setQuerySelectType();
result.setDistinct(true);
result.setLimit(limit == null ? Query.NOLIMIT : limit);
result.setOffset(offset == null ? Query.NOLIMIT : offset);
result.getProject().add(concept.getVar());
Element e = concept.getElement();
if(e instanceof ElementSubQuery) {
e = ElementUtils.createElementGroup(e);
}
result.setQueryPattern(e);
// String str = result.toString();
// System.out.println(str);
return result;
}
代码示例来源:origin: vivo-project/Vitro
@Override
public Model getTriples(RDFNode subject, RDFNode predicate, RDFNode object, long limit, long offset) throws RDFServiceException {
Query query = QueryFactory.create("CONSTRUCT WHERE { ?s ?p ?o }", Syntax.syntaxSPARQL_11);
QuerySolutionMap map = new QuerySolutionMap();
if ( subject != null ) {
map.add("s", subject);
}
if ( predicate != null ) {
map.add("p", predicate);
}
if ( object != null ) {
map.add("o", object);
}
query.setOffset(offset);
query.setLimit(limit);
Model triples = ModelFactory.createDefaultModel();
DatasetWrapper dw = getDatasetWrapper();
try {
Dataset d = dw.getDataset();
try (QueryExecution qexec = QueryExecutionFactory.create(query, d, map)) {
qexec.execConstruct(triples);
}
return triples;
} finally {
dw.close();
}
}
内容来源于网络,如有侵权,请联系作者删除!