A C D F G H I J K M N O P R S T U V W

A

allowOverwriteFiles - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

C

classTag - Variable in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializationWrapper

convertToQuad - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

convertToTriple - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

create(JavaRDD<T>, SerializableBiConsumer<T, StreamRDF>, Function<JavaRDD<T>, JavaRDD<Triple>>, Function<JavaRDD<T>, JavaRDD<Quad>>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

Create method.

createDefault() - Static method in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry

createForDataset(JavaRDD<Dataset>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

createForQuad(JavaRDD<Quad>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

createForTriple(JavaRDD<Triple>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

createStreamRDFFactory(RDFFormat, boolean, PrefixMapping) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

Create a function that can create a StreamRDF instance that is backed by the given OutputStream.

D

deletePartitionFolderAfterMerge - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

deserialize(ClassTag<T>, byte[]) - Static method in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializer

F

FormatEntry(Class<?>, Class<?>, Class<? extends OutputFormat>) - Constructor for class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry.FormatEntry

G

get(Lang) - Method in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry

getDefaults() - Static method in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry

The default registry for elephas output formats based on Lang.

getGlobalPrefixMapping() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

getInstance() - Static method in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry

getKeyClass() - Method in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry.FormatEntry

getOutputFormat() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

getOutputFormatClass() - Method in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry.FormatEntry

getPartitionFolder() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

getSerializer() - Static method in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializer

getTargetFile() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

getValue() - Method in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializationWrapper

getValueClass() - Method in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry.FormatEntry

getValueSerialized() - Method in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializationWrapper

globalPrefixMapping - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

H

hadoopConfiguration - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

I

isAllowOverwriteFiles() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

isDeletePartitionFolderAfterMerge() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

isMapQuadsToTriplesForTripleLangs() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

isPartitionsAsIndependentFiles() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

isUseCoalesceOne() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

isUseElephas() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

J

JavaKryoSerializationWrapper<T> - Class in net.sansa_stack.rdf.spark.utils.kryo.io

A wrapper around some unserializable objects that make them both Java serializable.

JavaKryoSerializationWrapper(T) - Constructor for class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializationWrapper

JavaKryoSerializer - Class in net.sansa_stack.rdf.spark.utils.kryo.io

Java object serialization using Kryo.

JavaKryoSerializer() - Constructor for class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializer

K

keyClass - Variable in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry.FormatEntry

M

mapQuadsToTriplesForTripleLangs - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

Whether to convert quads to triples if a triple-based output format is requested

mergeFolder(Path, Path, String, Comparator<? super Path>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

mutate(Consumer<RddRdfSaver<T>>) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

Pass this object to a consumer.

N

net.sansa_stack.rdf.spark.io - package net.sansa_stack.rdf.spark.io

net.sansa_stack.rdf.spark.kryo.sparqlify - package net.sansa_stack.rdf.spark.kryo.sparqlify

net.sansa_stack.rdf.spark.utils.kryo.io - package net.sansa_stack.rdf.spark.utils.kryo.io

O

outputFormat - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

outputFormatClass - Variable in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry.FormatEntry

OutputFormatRdfRegistry - Class in net.sansa_stack.rdf.spark.io

OutputFormatRdfRegistry() - Constructor for class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry

OutputFormatRdfRegistry.FormatEntry - Class in net.sansa_stack.rdf.spark.io

P

partitionFolder - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

partitionMapperNQuads(Iterator<Quad>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

partitionMapperNTriples(Iterator<Triple>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

Save the RDD to a single file.

partitionMapperRDFStream(Function<OutputStream, StreamRDF>, BiConsumer<? super T, StreamRDF>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

partitionsAsIndependentFiles - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

R

rdd - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

RddRdfSaver<T> - Class in net.sansa_stack.rdf.spark.io

A fluent API for configuration of how to save an RDD of RDF data to disk.

RddRdfSaver(JavaRDD<T>, BiConsumer<T, StreamRDF>, Function<JavaRDD<T>, JavaRDD<Triple>>, Function<JavaRDD<T>, JavaRDD<Quad>>) - Constructor for class net.sansa_stack.rdf.spark.io.RddRdfSaver

read(Kryo, Input, Class<RestrictedExpr>) - Method in class net.sansa_stack.rdf.spark.kryo.sparqlify.RestrictedExprSerializer

register(Lang, OutputFormatRdfRegistry.FormatEntry) - Method in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry

registry - Variable in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry

RestrictedExprSerializer - Class in net.sansa_stack.rdf.spark.kryo.sparqlify

RestrictedExprSerializer() - Constructor for class net.sansa_stack.rdf.spark.kryo.sparqlify.RestrictedExprSerializer

run() - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

Run the save action according to configuration

S

saveToFolder(JavaRDD<T>, String, RDFFormat, boolean, PrefixMapping, BiConsumer<T, StreamRDF>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

Save the data in Trig/Turtle or its sub-formats (n-quads/n-triples) format.

saveUsingElephas(JavaRDD<T>, Path, Lang, SerializableFunction<? super T, ?>) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

sendRecordToStreamRDF - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

serialize(ClassTag<T>, T) - Static method in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializer

setAllowOverwriteFiles(boolean) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setDeletePartitionFolderAfterMerge(boolean) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setGlobalPrefixMapping(PrefixMapping) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

Set a prefix mapping to be used "globally" across all partitions.

setMapQuadsToTriplesForTripleLangs(boolean) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

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.

setOutputFormat(RDFFormat) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setPartitionFolder(Path) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setPartitionFolder(String) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setPartitionsAsIndependentFiles(boolean) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setTargetFile(Path) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setTargetFile(String) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setUseCoalesceOne(boolean) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setUseElephas(boolean) - Method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

setValueSerialized(byte[]) - Method in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializationWrapper

sparkContext - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

T

targetFile - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

toString(PrefixMapping, RDFFormat) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

Convert a prefix mapping to a string

U

useCoalesceOne - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

useElephas - Variable in class net.sansa_stack.rdf.spark.io.RddRdfSaver

V

validateOutFolder(Path, Configuration, boolean) - Static method in class net.sansa_stack.rdf.spark.io.RddRdfSaver

value - Variable in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializationWrapper

valueClass - Variable in class net.sansa_stack.rdf.spark.io.OutputFormatRdfRegistry.FormatEntry

valueSerialized - Variable in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializationWrapper

W

wrap(Function<I, O>) - Static method in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializationWrapper

wrap(Function<I, O>) - Static method in class net.sansa_stack.rdf.spark.utils.kryo.io.JavaKryoSerializationWrapper

write(Kryo, Output, RestrictedExpr) - Method in class net.sansa_stack.rdf.spark.kryo.sparqlify.RestrictedExprSerializer

A C D F G H I J K M N O P R S T U V W