org.apache.jena.sparql.engine.ExecutionContext.getActiveGraph()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(7.3k)|赞(0)|评价(0)|浏览(71)

本文整理了Java中org.apache.jena.sparql.engine.ExecutionContext.getActiveGraph()方法的一些代码示例,展示了ExecutionContext.getActiveGraph()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。ExecutionContext.getActiveGraph()方法的具体详情如下:
包路径:org.apache.jena.sparql.engine.ExecutionContext
类名称:ExecutionContext
方法名:getActiveGraph

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) ;
}

相关文章