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

Class ConsecutiveGraphMergerMergerForResourceInDataset

java.lang.Object

org.aksw.jenax.sparql.query.rx.StreamUtils.ConsecutiveNamedGraphMergerCore<org.aksw.jenax.sparql.relation.dataset.NodesInDataset>

org.aksw.jenax.sparql.rx.op.ConsecutiveGraphMergerMergerForResourceInDataset

public class ConsecutiveGraphMergerMergerForResourceInDataset
extends StreamUtils.ConsecutiveNamedGraphMergerCore<org.aksw.jenax.sparql.relation.dataset.NodesInDataset>

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<org.apache.jena.graph.Node,List<org.apache.jena.graph.Node>>	graphToNodes

Fields inherited from class org.aksw.jenax.sparql.query.rx.StreamUtils.ConsecutiveNamedGraphMergerCore

pending

Constructor Summary

Constructors

Constructor	Description
ConsecutiveGraphMergerMergerForResourceInDataset()

Method Summary

Modifier and Type	Method	Description
Optional<org.aksw.jenax.sparql.relation.dataset.NodesInDataset>	accept(org.aksw.jenax.sparql.relation.dataset.NodesInDataset grid)
protected org.aksw.jenax.sparql.relation.dataset.NodesInDataset	mapResult(Set<org.apache.jena.graph.Node> readyGraphs, org.apache.jena.query.Dataset dataset)

Methods inherited from class org.aksw.jenax.sparql.query.rx.StreamUtils.ConsecutiveNamedGraphMergerCore

accept, getPendingDataset

Methods inherited from class java.lang.Object

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

Field Details

graphToNodes

protected Map<org.apache.jena.graph.Node,List<org.apache.jena.graph.Node>> graphToNodes

Constructor Details

ConsecutiveGraphMergerMergerForResourceInDataset

public ConsecutiveGraphMergerMergerForResourceInDataset()

Method Details

accept

public Optional<org.aksw.jenax.sparql.relation.dataset.NodesInDataset> accept(org.aksw.jenax.sparql.relation.dataset.NodesInDataset grid)

mapResult

protected org.aksw.jenax.sparql.relation.dataset.NodesInDataset mapResult(Set<org.apache.jena.graph.Node> readyGraphs,
 org.apache.jena.query.Dataset dataset)

Specified by:

mapResult in class StreamUtils.ConsecutiveNamedGraphMergerCore<org.aksw.jenax.sparql.relation.dataset.NodesInDataset>