Uses of Class
net.sansa_stack.rdf.spark.io.RddRdfSaver

Packages that use RddRdfSaver

Package	Description
net.sansa_stack.rdf.spark.io

Uses of RddRdfSaver in net.sansa_stack.rdf.spark.io

Methods in net.sansa_stack.rdf.spark.io that return RddRdfSaver

Modifier and Type	Method and Description
static <T> RddRdfSaver	RddRdfSaver.create(org.apache.spark.api.java.JavaRDD<T> rdd, org.aksw.commons.lambda.serializable.SerializableBiConsumer<T,org.apache.jena.riot.system.StreamRDF> sendRecordToStreamRDF, Function<org.apache.spark.api.java.JavaRDD<T>,org.apache.spark.api.java.JavaRDD<org.apache.jena.graph.Triple>> convertToTriple, Function<org.apache.spark.api.java.JavaRDD<T>,org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.core.Quad>> convertToQuad) Create method.
static RddRdfSaver<org.apache.jena.query.Dataset>	RddRdfSaver.createForDataset(org.apache.spark.api.java.JavaRDD<org.apache.jena.query.Dataset> rdd)
static RddRdfSaver<org.apache.jena.sparql.core.Quad>	RddRdfSaver.createForQuad(org.apache.spark.api.java.JavaRDD<org.apache.jena.sparql.core.Quad> rdd)
static RddRdfSaver<org.apache.jena.graph.Triple>	RddRdfSaver.createForTriple(org.apache.spark.api.java.JavaRDD<org.apache.jena.graph.Triple> rdd)
RddRdfSaver<T>	RddRdfSaver.mutate(Consumer<RddRdfSaver<T>> action) Pass this object to a consumer.
RddRdfSaver<T>	RddRdfSaver.setAllowOverwriteFiles(boolean allowOverwriteFiles)
RddRdfSaver<T>	RddRdfSaver.setDeletePartitionFolderAfterMerge(boolean deletePartitionFolderAfterMerge)
RddRdfSaver<T>	RddRdfSaver.setGlobalPrefixMapping(org.apache.jena.shared.PrefixMapping globalPrefixMapping) Set a prefix mapping to be used "globally" across all partitions.
RddRdfSaver	RddRdfSaver.setMapQuadsToTriplesForTripleLangs(boolean mapQuadsToTriplesForTripleLangs) Whether to convert quads to triples if a triple-based output format is requested Jena by default discards any quad outside of the default graph when writing to a triple format.
RddRdfSaver<T>	RddRdfSaver.setOutputFormat(org.apache.jena.riot.RDFFormat outputFormat)
RddRdfSaver<T>	RddRdfSaver.setPartitionFolder(org.apache.hadoop.fs.Path partitionFolder)
RddRdfSaver<T>	RddRdfSaver.setPartitionFolder(String partitionFolder)
RddRdfSaver<T>	RddRdfSaver.setPartitionsAsIndependentFiles(boolean partitionsAsIndependentFiles)
RddRdfSaver<T>	RddRdfSaver.setTargetFile(org.apache.hadoop.fs.Path targetFile)
RddRdfSaver<T>	RddRdfSaver.setTargetFile(String targetFile)
RddRdfSaver<T>	RddRdfSaver.setUseElephas(boolean useElephas)

Method parameters in net.sansa_stack.rdf.spark.io with type arguments of type RddRdfSaver

Modifier and Type	Method and Description
RddRdfSaver<T>	RddRdfSaver.mutate(Consumer<RddRdfSaver<T>> action) Pass this object to a consumer.