Uses of Interface
eu.fbk.rdfpro.RDFProcessor

Packages that use RDFProcessor

Package	Description
eu.fbk.rdfpro	RDFpro library.

Uses of RDFProcessor in eu.fbk.rdfpro

Fields in eu.fbk.rdfpro declared as RDFProcessor

Modifier and Type	Field and Description
static RDFProcessor	RDFProcessors.IDENTITY The identity RDFProcessor that returns the input RDF stream unchanged.
static RDFProcessor	RDFProcessors.NIL The null RDFProcessor that always produces an empty RDF stream.

Methods in eu.fbk.rdfpro that return RDFProcessor

Modifier and Type	Method and Description
static RDFProcessor	RDFProcessors.download(boolean parallelize, boolean preserveBNodes, String endpointURL, String query) Creates an RDFProcessor that retrieves data from a SPARQL endpoint and inject it in the RDF stream at each pass.
static RDFProcessor	RDFProcessors.inject(RDFSource source) Creates an RDFProcessor that injects in the RDF stream the data loaded from the specified RDFSource.
static RDFProcessor	RDFProcessors.mapReduce(Mapper mapper, Reducer reducer, boolean deduplicate) Creates an RDFProcessor that processes the RDF stream in a MapReduce fashion.
static RDFProcessor	RDFProcessors.parallel(SetOperator operator, RDFProcessor... processors) Returns an RDFProcessor performing the parallel composition of the processors specified, using the given SetOperator to merge their results.
static RDFProcessor	RDFProcessors.parse(boolean tokenize, String... args) Creates an RDFProcessor by parsing the supplied specification string(s).
static RDFProcessor	RDFProcessors.prefix(Map<String,String> nsToPrefixMap) Creates an RDFProcessor that augments the RDF stream with prefix-to-namespace bindings from the supplied map or from prefix.cc.
static RDFProcessor	RDFProcessors.rdfs(RDFSource tbox, org.openrdf.model.Resource tboxContext, boolean decomposeOWLAxioms, boolean dropBNodeTypes, String... excludedRules) Creates an RDFProcessor that computes the RDFS closure of the RDF stream based on the TBox separately supplied.
static RDFProcessor	RDFProcessors.read(boolean parallelize, boolean preserveBNodes, String baseURI, org.openrdf.rio.ParserConfig config, String... locations) Creates an RDFProcessor that reads data from the files specified and inject it in the RDF stream at each pass.
static RDFProcessor	RDFProcessors.rules(Ruleset ruleset, Mapper mapper, boolean dropBNodeTypes, boolean deduplicate) Returns an RDFProcessor that applies the ruleset specified on input statements either as a whole or partitioned based on an optional Mapper.
static RDFProcessor	RDFProcessors.rules(Ruleset ruleset, Mapper mapper, boolean dropBNodeTypes, boolean deduplicate, RDFSource tboxData, boolean emitTBox, org.openrdf.model.URI tboxContext) Returns an RDFProcessor that expands the ruleset based on the supplied TBox and applies the resulting ruleset on input statements either as a whole or partitioned based on an optional Mapper.
static RDFProcessor	RDFProcessors.sequence(RDFProcessor... processors) Returns an RDFProcessor performing the sequence composition of the supplied RDFProcessors.
static RDFProcessor	RDFProcessors.smush(String... rankedNamespaces) Creates an RDFProcessor performing owl:sameAs smushing.
static RDFProcessor	RDFProcessors.stats(String outputNamespace, org.openrdf.model.URI sourceProperty, org.openrdf.model.URI sourceContext, Long threshold, boolean processCooccurrences) Creates an RDFProcessor extracting VOID structural statistics from the RDF stream.
static RDFProcessor	RDFProcessors.tbox() Returns a RDFProcessor that extracts the TBox of data in the RDF stream.
static RDFProcessor	RDFProcessors.tee(org.openrdf.rio.RDFHandler... handlers) Creates an RDFProcessor that duplicates data of the RDF stream to the RDFHandlers specified.
static RDFProcessor	RDFProcessors.track(Tracker tracker) Returns an RDFProcessor that tracks the number of statements flowing through it using the supplied Tracker object.
static RDFProcessor	RDFProcessors.transform(Transformer transformer) Returns a RDFProcessor that applies the supplied Transformer to each input triple, producing the transformed triples in output.
static RDFProcessor	RDFProcessors.unique(boolean mergeContexts) Creates an RDFProcessor that removes duplicate from the RDF stream, optionally merging similar statements with different contexts in a unique statement.
static RDFProcessor	RDFProcessors.upload(String endpointURL) Creates an RDFProcessor that uploads data of the RDF stream to the SPARQL endpoint specified, using SPARQL Update INSERT DATA calls.
static RDFProcessor	RDFProcessors.write(org.openrdf.rio.WriterConfig config, int chunkSize, String... locations) Creates an RDFProcessor that writes data of the RDF stream to the files specified.

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

Modifier and Type	Method and Description
static RDFProcessor	RDFProcessors.parallel(SetOperator operator, RDFProcessor... processors) Returns an RDFProcessor performing the parallel composition of the processors specified, using the given SetOperator to merge their results.
static RDFProcessor	RDFProcessors.sequence(RDFProcessor... processors) Returns an RDFProcessor performing the sequence composition of the supplied RDFProcessors.