Package org.aksw.jenax.sparql.rx.op

Class FlowOfRdfNodesInDatasetsOps

java.lang.Object
org.aksw.jenax.sparql.rx.op.FlowOfRdfNodesInDatasetsOps
public class FlowOfRdfNodesInDatasetsOps extends Object

  • Constructor Summary

    Constructors
    Constructor
    Description
    FlowOfRdfNodesInDatasetsOps()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    static Function<? super org.apache.jena.rdfconnection.SparqlQueryConnection,org.apache.jena.graph.Node>
    createKeyMapper(String keyArg, Function<? super String,? extends org.apache.jena.query.Query> queryParser, org.apache.jena.query.Query fallback)
     
    static io.reactivex.rxjava3.core.FlowableTransformer<org.aksw.jenax.arq.dataset.api.ResourceInDataset,org.aksw.jenax.arq.dataset.api.ResourceInDataset>
    createTransformerFromGroupedTransform(io.reactivex.rxjava3.core.FlowableTransformer<org.aksw.jenax.sparql.relation.dataset.NodesInDataset,org.aksw.jenax.sparql.relation.dataset.NodesInDataset> innerTransform)
    Adapter to create a transformed for ResourceInDataset based on one for NodesInDataset.
    static io.reactivex.rxjava3.core.FlowableTransformer<org.aksw.jenax.arq.dataset.api.ResourceInDataset,org.aksw.jenax.sparql.relation.dataset.NodesInDataset>
    groupedResourceInDataset()
    Accumulate consecutive ResourceInDataset items which share the same Dataset or underlying DatasetGraph by reference equality into an Entryinvalid input: '<'Dataset, List>
    static Function<org.apache.jena.query.Dataset,org.aksw.jenax.sparql.relation.dataset.NodesInDataset>
    mapToNodesInDataset(org.apache.jena.query.Query nodeSelector)
    Operator that marks (graph, node) pairs from a dataset using a SELECT query with two result variables and returns them in a NodesInDataset object.
    static io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.sparql.relation.dataset.NodesInDataset>
    mergeConsecutiveResourceInDatasets(io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.sparql.relation.dataset.NodesInDataset> in)
     
    static io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.arq.dataset.api.ResourceInDataset>
    naturalResources(org.apache.jena.query.Dataset dataset)
    Return a flow over the natural resources in the named graphs of a dataset.
    static io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.arq.dataset.api.ResourceInDataset>
    ungrouperResourceInDataset(org.aksw.jenax.sparql.relation.dataset.NodesInDataset grid)
    Intended to be used with flatMap flow.flatMap(...)
    static List<org.aksw.jenax.arq.dataset.api.ResourceInDataset>
    ungroupResourceInDataset(org.aksw.jenax.sparql.relation.dataset.NodesInDataset grid)
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • FlowOfRdfNodesInDatasetsOps

      public FlowOfRdfNodesInDatasetsOps()

  • Method Details

    • naturalResources

      public static io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.arq.dataset.api.ResourceInDataset> naturalResources(org.apache.jena.query.Dataset dataset)
      Return a flow over the natural resources in the named graphs of a dataset. A natural resource is a node that has has the same name (IRI) as the graph.
      Parameters:
      dataset -
      Returns:

    • mapToNodesInDataset

      public static Function<org.apache.jena.query.Dataset,org.aksw.jenax.sparql.relation.dataset.NodesInDataset> mapToNodesInDataset(org.apache.jena.query.Query nodeSelector)
      Operator that marks (graph, node) pairs from a dataset using a SELECT query with two result variables and returns them in a NodesInDataset object.
      Parameters:
      nodeSelector -
      Returns:

    • groupedResourceInDataset

      public static io.reactivex.rxjava3.core.FlowableTransformer<org.aksw.jenax.arq.dataset.api.ResourceInDataset,org.aksw.jenax.sparql.relation.dataset.NodesInDataset> groupedResourceInDataset()
      Accumulate consecutive ResourceInDataset items which share the same Dataset or underlying DatasetGraph by reference equality into an Entryinvalid input: '<'Dataset, List>
      Returns:

    • ungroupResourceInDataset

      public static List<org.aksw.jenax.arq.dataset.api.ResourceInDataset> ungroupResourceInDataset(org.aksw.jenax.sparql.relation.dataset.NodesInDataset grid)

    • ungrouperResourceInDataset

      public static io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.arq.dataset.api.ResourceInDataset> ungrouperResourceInDataset(org.aksw.jenax.sparql.relation.dataset.NodesInDataset grid)
      Intended to be used with flatMap flow.flatMap(...)
      Parameters:
      grid -
      Returns:

    • createKeyMapper

      public static Function<? super org.apache.jena.rdfconnection.SparqlQueryConnection,org.apache.jena.graph.Node> createKeyMapper(String keyArg, Function<? super String,? extends org.apache.jena.query.Query> queryParser, org.apache.jena.query.Query fallback)

    • mergeConsecutiveResourceInDatasets

      public static io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.sparql.relation.dataset.NodesInDataset> mergeConsecutiveResourceInDatasets(io.reactivex.rxjava3.core.Flowable<org.aksw.jenax.sparql.relation.dataset.NodesInDataset> in)

    • createTransformerFromGroupedTransform

      public static io.reactivex.rxjava3.core.FlowableTransformer<org.aksw.jenax.arq.dataset.api.ResourceInDataset,org.aksw.jenax.arq.dataset.api.ResourceInDataset> createTransformerFromGroupedTransform(io.reactivex.rxjava3.core.FlowableTransformer<org.aksw.jenax.sparql.relation.dataset.NodesInDataset,org.aksw.jenax.sparql.relation.dataset.NodesInDataset> innerTransform)
      Adapter to create a transformed for ResourceInDataset based on one for NodesInDataset.
      Parameters:
      innerTransform -
      Returns: