Class RecordReaderRdfTrigDataset.AccumulatingDataset
- java.lang.Object
-
- net.sansa_stack.hadoop.format.jena.trig.RecordReaderRdfTrigDataset.AccumulatingDataset
-
- All Implemented Interfaces:
Accumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.aksw.jenax.arq.dataset.api.DatasetOneNg,org.aksw.jenax.arq.dataset.api.DatasetOneNg>
- Enclosing class:
- RecordReaderRdfTrigDataset
public static class RecordReaderRdfTrigDataset.AccumulatingDataset extends Object implements Accumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.aksw.jenax.arq.dataset.api.DatasetOneNg,org.aksw.jenax.arq.dataset.api.DatasetOneNg>
-
-
Constructor Summary
Constructors Constructor Description AccumulatingDataset()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
accumulate(org.aksw.jenax.arq.dataset.api.DatasetOneNg accumulator, org.apache.jena.sparql.core.Quad item)
org.aksw.jenax.arq.dataset.api.DatasetOneNg
accumulatedValue(org.aksw.jenax.arq.dataset.api.DatasetOneNg accumulator)
org.apache.jena.graph.Node
classify(org.apache.jena.sparql.core.Quad item)
org.aksw.jenax.arq.dataset.api.DatasetOneNg
createAccumulator(org.apache.jena.graph.Node groupKey)
-
-
-
Method Detail
-
classify
public org.apache.jena.graph.Node classify(org.apache.jena.sparql.core.Quad item)
- Specified by:
classify
in interfaceAccumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.aksw.jenax.arq.dataset.api.DatasetOneNg,org.aksw.jenax.arq.dataset.api.DatasetOneNg>
-
createAccumulator
public org.aksw.jenax.arq.dataset.api.DatasetOneNg createAccumulator(org.apache.jena.graph.Node groupKey)
- Specified by:
createAccumulator
in interfaceAccumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.aksw.jenax.arq.dataset.api.DatasetOneNg,org.aksw.jenax.arq.dataset.api.DatasetOneNg>
-
accumulate
public void accumulate(org.aksw.jenax.arq.dataset.api.DatasetOneNg accumulator, org.apache.jena.sparql.core.Quad item)
- Specified by:
accumulate
in interfaceAccumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.aksw.jenax.arq.dataset.api.DatasetOneNg,org.aksw.jenax.arq.dataset.api.DatasetOneNg>
-
accumulatedValue
public org.aksw.jenax.arq.dataset.api.DatasetOneNg accumulatedValue(org.aksw.jenax.arq.dataset.api.DatasetOneNg accumulator)
- Specified by:
accumulatedValue
in interfaceAccumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.aksw.jenax.arq.dataset.api.DatasetOneNg,org.aksw.jenax.arq.dataset.api.DatasetOneNg>
-
-