本文整理了Java中org.apache.jena.sparql.engine.ExecutionContext.getActiveGraph()
方法的一些代码示例,展示了ExecutionContext.getActiveGraph()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ExecutionContext.getActiveGraph()
方法的具体详情如下:
包路径:org.apache.jena.sparql.engine.ExecutionContext
类名称:ExecutionContext
方法名:getActiveGraph
[英]Return the active graph (the one matching is against at this point in the query. May be null if unknown or not applicable - for example, doing quad store access or when sorting
[中]返回活动图形(此时查询中匹配的图形是反对的。如果未知或不适用,则可能为空-例如,执行四元存储访问或排序时
代码示例来源:origin: apache/jena
public OpExecutorTDB2(ExecutionContext execCxt)
{
super(execCxt) ;
// NB. The dataset may be a TDB one, or a general one.
// Any merged union graph magic (for a TDB dataset was handled
// in QueryEngineTDB).
isForTDB = (execCxt.getActiveGraph() instanceof GraphTDB) ;
}
代码示例来源:origin: apache/jena
public OpExecutorTDB1(ExecutionContext execCxt)
{
super(execCxt) ;
// NB. The dataset may be a TDB one, or a general one.
// Any merged union graph magic (for a TDB dataset was handled
// in QueryEngineTDB).
isForTDB = (execCxt.getActiveGraph() instanceof GraphTDB) ;
}
代码示例来源:origin: apache/jena
@Override
protected QueryIterator execute(OpBGP opBGP, QueryIterator input)
{
if ( ! isForTDB )
return super.execute(opBGP, input) ;
GraphTDB graph = (GraphTDB)execCxt.getActiveGraph() ;
return executeBGP(graph, opBGP, input, null, execCxt) ;
}
代码示例来源:origin: apache/jena
public FunctionEnvBase(ExecutionContext execCxt)
{
this(execCxt.getContext(), execCxt.getActiveGraph(), execCxt.getDataset()) ;
execContext = execCxt ;
}
代码示例来源:origin: apache/jena
private QueryIterator verify(Binding binding, Node containerNode, Node member, ExecutionContext execCxt)
{
int count = GraphContainerUtils.countContainerMember(execCxt.getActiveGraph(), containerNode, typeNode, member) ;
return new QueryIterYieldN(count, binding, execCxt) ;
}
代码示例来源:origin: apache/jena
@Override
protected QueryIterator execObjectBound(Binding binding, Var listVar, Node predicate, Node length,
ExecutionContext execCxt)
{
Graph graph = execCxt.getActiveGraph() ;
return length(binding, graph, listVar, Var.alloc(length) , execCxt) ;
}
}
代码示例来源:origin: apache/jena
@Override
protected QueryIterator execute(OpBGP opBGP, QueryIterator input)
{
if ( ! isForTDB )
return super.execute(opBGP, input) ;
GraphTDB graph = (GraphTDB)execCxt.getActiveGraph() ;
return executeBGP(graph, opBGP, input, null, execCxt) ;
}
代码示例来源:origin: apache/jena
private QueryIterBlockTriples(QueryIterator input,
BasicPattern pattern ,
ExecutionContext execContext)
{
super(input, execContext) ;
this.pattern = pattern ;
graph = execContext.getActiveGraph() ;
// Create a chain of triple iterators.
QueryIterator chain = getInput() ;
for (Triple triple : pattern)
chain = new QueryIterTriplePattern(chain, triple, execContext) ;
output = chain ;
}
代码示例来源:origin: rdfhdt/hdt-java
@Override
protected QueryIterator execute(OpBGP opBGP, QueryIterator input)
{
if ( ! isForHDT )
return super.execute(opBGP, input) ;
HDTGraph graph = (HDTGraph)execCxt.getActiveGraph() ;
return executeBGP(graph, opBGP, input, null, execCxt);
}
代码示例来源:origin: apache/jena
private QueryIterator members(Binding binding, Node listNode, Var itemVar, ExecutionContext execCxt)
{
List<Node> members = GraphList.members(new GNode(execCxt.getActiveGraph(), listNode)) ;
return new QueryIterExtendByVar(binding, itemVar, members.iterator(), execCxt) ;
}
代码示例来源:origin: apache/jena
@Override
public QueryIterator execute(BasicPattern pattern, QueryIterator input, ExecutionContext execCxt) {
if ( input == null )
Log.error(this, "Null input to " + Lib.classShortName(this.getClass())) ;
Graph graph = execCxt.getActiveGraph() ;
// Choose reorder transformation and execution strategy.
ReorderTransformation reorder = reorderFixed ;
StageGenerator executor = StageBuilder.executeInline ;
return execute(pattern, reorder, executor, input, execCxt) ;
}
代码示例来源:origin: apache/jena
@Override
protected QueryIterator execObjectBound(Binding binding, Var listVar, Node predicate, Node object, ExecutionContext execCxt)
{
// Given a concrete node, find lists it's in
GNode gnode = new GNode(execCxt.getActiveGraph(), object) ;
List<Node> lists = GraphList.listFromMember(gnode) ;
return new QueryIterExtendByVar(binding, listVar, lists.iterator(), execCxt) ;
}
代码示例来源:origin: apache/jena
private QueryIterator verify(Binding binding, Node listNode, Node member, ExecutionContext execCxt)
{
int count = GraphList.occurs(new GNode(execCxt.getActiveGraph(), listNode), member) ;
return new QueryIterYieldN(count, binding) ;
}
代码示例来源:origin: org.apache.jena/jena-csv
private QueryIterPropertyTable(QueryIterator input, BasicPattern pattern,
ExecutionContext execContext) {
super(input, execContext);
this.pattern = pattern;
graph = execContext.getActiveGraph();
// Create a chain of triple iterators.
QueryIterator chain = getInput();
Collection<BasicPattern> patterns = sort(pattern);
for (BasicPattern p : patterns)
chain = new QueryIterPropertyTableRow(chain, p, execContext);
output = chain;
}
代码示例来源:origin: Galigator/openllet
public QueryIterator build(final QueryIterator input, final ExecutionContext execCxt)
{
final Graph graph = execCxt.getActiveGraph();
if (!(graph instanceof PelletInfGraph))
throw new UnsupportedOperationException("A Pellet-backed model is required");
final PelletInfGraph pellet = (PelletInfGraph) graph;
pellet.prepare();
final Query query = parsePattern(pellet);
if (query != null)
return new PelletQueryIterator(pellet, query, input, execCxt);
else
return new StageGeneratorGeneric().execute(_pattern, input, execCxt);
}
代码示例来源:origin: apache/jena
private QueryIterator execEvaluatedConcrete(Binding binding, Node containerNode, Node predicate, Node member,
ExecutionContext execCxt)
{
QueryIterator input = QueryIterSingleton.create(binding, execCxt) ;
Graph graph = execCxt.getActiveGraph() ;
QueryIterator qIter = new QueryIterTriplePattern(input, new Triple(containerNode, predicate, member), execCxt) ;
return qIter ;
}
代码示例来源:origin: org.apache.jena/jena-csv
@Override
public QueryIterator execute(BasicPattern pattern, QueryIterator input, ExecutionContext execCxt)
{
// --- In case this isn't for GraphPropertyTable
Graph g = execCxt.getActiveGraph() ;
if ( ! ( g instanceof GraphPropertyTable ) )
return above.execute(pattern, input, execCxt) ;
if (pattern.size() <= 1){
return above.execute(pattern, input, execCxt) ;
}
return QueryIterPropertyTable.create(input, pattern, execCxt);
}
代码示例来源:origin: apache/jena
@Override
public QueryIterator execute(BasicPattern pattern, QueryIterator input, ExecutionContext execCxt)
{
// --- In case this isn't for TDB
Graph g = execCxt.getActiveGraph() ;
if ( ! ( g instanceof GraphTDB ) )
// Not us - bounce up the StageGenerator chain
return above.execute(pattern, input, execCxt) ;
GraphTDB graph = (GraphTDB)g ;
Predicate<Tuple<NodeId>> filter = QC2.getFilter(execCxt.getContext()) ;
return SolverLib.execute(graph, pattern, input, filter, execCxt) ;
}
}
代码示例来源:origin: apache/jena
@Override
public QueryIterator execOneList(Binding binding, Node listNode, Node predicate, Node length, ExecutionContext execCxt)
{
Graph graph = execCxt.getActiveGraph() ;
if ( Var.isVar(listNode) )
throw new ARQInternalErrorException("listLength: Subject is a variable") ;
// Case : arg 1 (the list) is bound and arg 2 not bound => generate possibilities
// Case : arg 1 is bound and arg 2 is bound => test for membership.
if ( Var.isVar(length) )
return length(binding, graph, listNode, Var.alloc(length) , execCxt) ;
else
return verify(binding, graph, listNode, length, execCxt) ;
}
代码示例来源:origin: apache/jena
TripleMapper(Binding binding, Triple pattern, ExecutionContext cxt)
{
super(cxt) ;
this.s = substitute(pattern.getSubject(), binding) ;
this.p = substitute(pattern.getPredicate(), binding) ;
this.o = substitute(pattern.getObject(), binding) ;
this.binding = binding ;
Node s2 = tripleNode(s) ;
Node p2 = tripleNode(p) ;
Node o2 = tripleNode(o) ;
Graph graph = cxt.getActiveGraph() ;
this.graphIter = graph.find(s2, p2, o2) ;
}
内容来源于网络,如有侵权,请联系作者删除!