org.eclipse.rdf4j.query.algebra.Extension.getArg()方法的使用及代码示例

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

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

Extension.getArg介绍

暂无

代码示例

代码示例来源:origin: de.tudarmstadt.ukp.inception.rdf4j/rdf4j-spin

  1. @Override
  2. public void meet(Extension node)
  3. throws RDFHandlerException
  4. {
  5. node.getArg().visit(this);
  6. }

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-queryalgebra-evaluation

  1. @Override
  2. public void meet(Extension node) {
  3. if (node.getArg().getBindingNames().containsAll(filterVars)) {
  4. node.getArg().visit(this);
  5. }
  6. else {
  7. relocate(filter, node);
  8. }
  9. }

代码示例来源:origin: de.tudarmstadt.ukp.inception.rdf4j/rdf4j-queryalgebra-evaluation

  1. @Override
  2. public void meet(Extension node) {
  3. if (node.getArg().getBindingNames().containsAll(filterVars)) {
  4. node.getArg().visit(this);
  5. }
  6. else {
  7. relocate(filter, node);
  8. }
  9. }

代码示例来源:origin: Merck/Halyard

  1. }, extension.getArg(), bindings);

代码示例来源:origin: apache/incubator-rya

  1. @Override
  2. public void meet(Extension extensionNode) throws Exception {
  3. extensionNode.visitChildren(this);
  4. if (extensionNode.getArg() instanceof AggregationPipelineQueryNode && extensionNode.getParentNode() != null) {
  5. AggregationPipelineQueryNode pipelineNode = (AggregationPipelineQueryNode) extensionNode.getArg();
  6. if (pipelineNode.extend(extensionNode.getElements())) {
  7. extensionNode.replaceWith(pipelineNode);
  8. }
  9. }
  10. }

代码示例来源:origin: de.tudarmstadt.ukp.inception.rdf4j/rdf4j-spin

  1. @Override
  2. public void meet(Extension node)
  3. throws RDFHandlerException
  4. {
  5. if (inlineBindings != null && inlineBindings.extension == node) {
  6. // this is the first Extension node and has already been handled
  7. // by meetExtension()
  8. // to produce inline bindings in SELECT so we can skip it here
  9. node.getArg().visit(this);
  10. }
  11. else {
  12. // any further Extension nodes produce BIND() clauses
  13. node.getArg().visit(this);
  14. for (ExtensionElem elem : node.getElements()) {
  15. elem.visit(this);
  16. }
  17. }
  18. }

代码示例来源:origin: apache/incubator-rya

  1. @Override
  2. public void meet(final MultiProjection node) throws TopologyBuilderException {
  3. final String id = PROJECTION_PREFIX + UUID.randomUUID();
  4. final Optional<Side> side = getSide(node);
  5. final MultiProjectionProcessorSupplier supplier = new MultiProjectionProcessorSupplier(
  6. MultiProjectionEvaluator.make(node, bNodeIdFactory),
  7. result -> getResult(side, result));
  8. // If the arg is an Extension, then this node's grandchild is the next processing node.
  9. TupleExpr downstreamNode = node.getArg();
  10. if (downstreamNode instanceof Extension) {
  11. downstreamNode = ((Extension) downstreamNode).getArg();
  12. }
  13. entries.add(new ProcessorEntry(node, id, side, supplier, Lists.newArrayList(downstreamNode)));
  14. idMap.put(node, id);
  15. super.meet(node);
  16. }

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-queryalgebra-evaluation

  1. public CloseableIteration<BindingSet, QueryEvaluationException> evaluate(Extension extension,
  2. BindingSet bindings)
  3. throws QueryEvaluationException
  4. {
  5. CloseableIteration<BindingSet, QueryEvaluationException> result;
  6. try {
  7. result = this.evaluate(extension.getArg(), bindings);
  8. }
  9. catch (ValueExprEvaluationException e) {
  10. // a type error in an extension argument should be silently ignored
  11. // and
  12. // result in zero bindings.
  13. result = new EmptyIteration<BindingSet, QueryEvaluationException>();
  14. }
  15. result = new ExtensionIterator(extension, result, this);
  16. return result;
  17. }

代码示例来源:origin: de.tudarmstadt.ukp.inception.rdf4j/rdf4j-queryalgebra-evaluation

  1. public CloseableIteration<BindingSet, QueryEvaluationException> evaluate(Extension extension,
  2. BindingSet bindings)
  3. throws QueryEvaluationException
  4. {
  5. CloseableIteration<BindingSet, QueryEvaluationException> result;
  6. try {
  7. result = this.evaluate(extension.getArg(), bindings);
  8. }
  9. catch (ValueExprEvaluationException e) {
  10. // a type error in an extension argument should be silently ignored
  11. // and
  12. // result in zero bindings.
  13. result = new EmptyIteration<BindingSet, QueryEvaluationException>();
  14. }
  15. result = new ExtensionIterator(extension, result, this);
  16. return result;
  17. }

代码示例来源:origin: apache/incubator-rya

  1. @Override
  2. public void meet(final Projection node) throws TopologyBuilderException {
  3. final String id = PROJECTION_PREFIX + UUID.randomUUID();
  4. final Optional<Side> side = getSide(node);
  5. // If the arg is an Extension, there are rebindings that need to be
  6. // ignored since they do not have a processor node.
  7. TupleExpr downstreamNode = node.getArg();
  8. if (downstreamNode instanceof Extension) {
  9. downstreamNode = ((Extension) downstreamNode).getArg();
  10. }
  11. final ProjectionProcessorSupplier supplier = new ProjectionProcessorSupplier(
  12. ProjectionEvaluator.make(node),
  13. result -> getResult(side, result));
  14. entries.add(new ProcessorEntry(node, id, side, supplier, Lists.newArrayList(downstreamNode)));
  15. idMap.put(node, id);
  16. super.meet(node);
  17. }

代码示例来源:origin: apache/incubator-rya

  1. @Override
  2. public void meet(Extension node) {
  3. Set<String> argBindings = node.getArg().getBindingNames();
  4. if (typeRequirement != null) {
  5. node.getElements().removeIf(elem -> {
  6. if (varName.equals(elem.getName())) {
  7. ValueExpr expr = elem.getExpr();
  8. if (expr == null) {
  9. return true;
  10. }
  11. else if (expr instanceof Var) {
  12. String fromName = ((Var) expr).getName();
  13. if (getVarValue((Var) expr) == null && !argBindings.contains(fromName)) {
  14. return true;
  15. }
  16. }
  17. }
  18. return false;
  19. });
  20. meetUnaryTupleOperator(node);
  21. }
  22. }
  23. @Override

代码示例来源:origin: apache/incubator-rya

  1. if(extension.getArg() instanceof Group) {
  2. child = extension;
  3. } else {
  4. child = extension.getArg();

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-sail-lucene-api

  1. @Override
  2. public void updateQueryModelNodes(boolean hasResult) {
  3. QueryModelNode replacementNode = hasResult ? new SingletonSet() : new EmptySet();
  4. geoStatement.replaceWith(replacementNode);
  5. if (hasResult) {
  6. filter.replaceWith(filter.getArg());
  7. }
  8. else {
  9. filter.replaceWith(new EmptySet());
  10. }
  11. if (functionParent instanceof ExtensionElem) {
  12. Extension extension = (Extension)functionParent.getParentNode();
  13. List<ExtensionElem> elements = extension.getElements();
  14. if (elements.size() > 1) {
  15. elements.remove(functionParent);
  16. }
  17. else {
  18. extension.replaceWith(extension.getArg());
  19. }
  20. }
  21. }
  22. }

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-sail-lucene-api

  1. @Override
  2. public void updateQueryModelNodes(boolean hasResult) {
  3. QueryModelNode replacementNode = hasResult ? new SingletonSet() : new EmptySet();
  4. geoStatement.replaceWith(replacementNode);
  5. if (hasResult) {
  6. filter.replaceWith(filter.getArg());
  7. }
  8. else {
  9. filter.replaceWith(new EmptySet());
  10. }
  11. QueryModelNode functionParent = distanceFunction.getParentNode();
  12. if (functionParent instanceof ExtensionElem) {
  13. Extension extension = (Extension)functionParent.getParentNode();
  14. List<ExtensionElem> elements = extension.getElements();
  15. if (elements.size() > 1) {
  16. elements.remove(functionParent);
  17. }
  18. else {
  19. extension.replaceWith(extension.getArg());
  20. }
  21. }
  22. }

代码示例来源:origin: apache/incubator-rya

  1. final TupleExpr arg = node.getArg();
  2. if(arg instanceof Group) {
  3. final Group group = (Group) arg;

代码示例来源:origin: ontop/ontop

  1. TranslationResult sub = translate(extension.getArg());
  2. final Stream<ExtensionElem> nontrivialBindings = extension.getElements().stream()

代码示例来源:origin: apache/incubator-rya

  1. @Test
  2. public void testUnsupportedExtension() throws Exception {
  3. StatementPattern sp = new StatementPattern(new Var("x"), constant(TAKES), new Var("c"));
  4. List<ExtensionElem> elements = Arrays.asList(new ExtensionElem(new Var("x"), "renamed"),
  5. new ExtensionElem(new Not(new ValueConstant(VF.createLiteral(true))), "notTrue"),
  6. new ExtensionElem(new ValueConstant(TAKES), "constant"));
  7. Extension extensionNode = new Extension(sp, elements);
  8. QueryRoot queryTree = new QueryRoot(extensionNode);
  9. SparqlToPipelineTransformVisitor visitor = new SparqlToPipelineTransformVisitor(collection);
  10. queryTree.visit(visitor);
  11. Assert.assertTrue(queryTree.getArg() instanceof Extension);
  12. Assert.assertEquals(elements, ((Extension) queryTree.getArg()).getElements());
  13. TupleExpr innerQuery = ((Extension) queryTree.getArg()).getArg();
  14. Assert.assertTrue(innerQuery instanceof AggregationPipelineQueryNode);
  15. AggregationPipelineQueryNode pipelineNode = (AggregationPipelineQueryNode) innerQuery;
  16. Assert.assertEquals(Sets.newHashSet("x", "c"), pipelineNode.getAssuredBindingNames());
  17. }
  18. }

相关文章