Uses of Interface
eu.fbk.rdfpro.Reducer

Packages that use Reducer

Package	Description
eu.fbk.rdfpro	RDFpro library.

Uses of Reducer in eu.fbk.rdfpro

Fields in eu.fbk.rdfpro declared as Reducer

Modifier and Type	Field and Description
static Reducer	Reducer.IDENTITY The identity reducer that emits all the quads of a partition unchanged.

Methods in eu.fbk.rdfpro that return Reducer

Modifier and Type	Method and Description
static Reducer	Reducer.concat(Reducer... reducers) Returns a Reducer that emits the output of multiple reductions on the same quad partition.
static Reducer	Reducer.filter(Reducer reducer, Predicate<org.openrdf.model.Statement> existsPredicate, Predicate<org.openrdf.model.Statement> forallPredicate) Returns a filtered version of the input reducer that operates only on partitions satisfying the existential and forall predicates supplied.

Methods in eu.fbk.rdfpro with parameters of type Reducer

Modifier and Type	Method and Description
static Reducer	Reducer.concat(Reducer... reducers) Returns a Reducer that emits the output of multiple reductions on the same quad partition.
static Reducer	Reducer.filter(Reducer reducer, Predicate<org.openrdf.model.Statement> existsPredicate, Predicate<org.openrdf.model.Statement> forallPredicate) Returns a filtered version of the input reducer that operates only on partitions satisfying the existential and forall predicates supplied.
static RDFProcessor	RDFProcessors.mapReduce(Mapper mapper, Reducer reducer, boolean deduplicate) Creates an RDFProcessor that processes the RDF stream in a MapReduce fashion.