net.sansa_stack.hadoop.jena.rdf.trig

Class RecordReaderTrigDataset.AccumulatingDataset

java.lang.Object

net.sansa_stack.hadoop.jena.rdf.trig.RecordReaderTrigDataset.AccumulatingDataset

All Implemented Interfaces:

Accumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.apache.jena.query.Dataset,org.apache.jena.query.Dataset>

Enclosing class:

RecordReaderTrigDataset

public static class RecordReaderTrigDataset.AccumulatingDataset
extends Object
implements Accumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.apache.jena.query.Dataset,org.apache.jena.query.Dataset>

Constructor Summary

Constructors

Constructor and Description
AccumulatingDataset()

Method Summary

Modifier and Type	Method and Description
void	accumulate(org.apache.jena.query.Dataset accumulator, org.apache.jena.sparql.core.Quad item)
org.apache.jena.query.Dataset	accumulatedValue(org.apache.jena.query.Dataset accumulator)
org.apache.jena.graph.Node	classify(org.apache.jena.sparql.core.Quad item)
org.apache.jena.query.Dataset	createAccumulator(org.apache.jena.graph.Node groupKey)

Methods inherited from class java.lang.Object

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

Methods inherited from interface net.sansa_stack.hadoop.generic.Accumulating

identity

Constructor Detail

AccumulatingDataset

public AccumulatingDataset()

Method Detail

classify

public org.apache.jena.graph.Node classify(org.apache.jena.sparql.core.Quad item)

Specified by:

classify in interface Accumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.apache.jena.query.Dataset,org.apache.jena.query.Dataset>

createAccumulator

public org.apache.jena.query.Dataset createAccumulator(org.apache.jena.graph.Node groupKey)

Specified by:

createAccumulator in interface Accumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.apache.jena.query.Dataset,org.apache.jena.query.Dataset>

accumulate

public void accumulate(org.apache.jena.query.Dataset accumulator,
                       org.apache.jena.sparql.core.Quad item)

Specified by:

accumulate in interface Accumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.apache.jena.query.Dataset,org.apache.jena.query.Dataset>

accumulatedValue

public org.apache.jena.query.Dataset accumulatedValue(org.apache.jena.query.Dataset accumulator)

Specified by:

accumulatedValue in interface Accumulating<org.apache.jena.sparql.core.Quad,org.apache.jena.graph.Node,org.apache.jena.query.Dataset,org.apache.jena.query.Dataset>