diff --git a/integration-tests/src/test/resources/quads/nanopub-rdf-stax.nq b/integration-tests/src/test/resources/quads/nanopub-rdf-stax.nq new file mode 100644 index 00000000..9798717e --- /dev/null +++ b/integration-tests/src/test/resources/quads/nanopub-rdf-stax.nq @@ -0,0 +1,28 @@ +# Nanopublication taken from: https://w3id.org/np/RAVE35-ydbImbVSkEf1S3r4ryuzihiAgSSPiZSgze8yZg + + . + . + . + . + . + . + . + . + "Apache Jena RIOT has facilities for streaming RDF statements (triples or quads) to/from byte streams using a number of serializations." . + . + . + . + . + "RSA" . + "MIGfMA0GCSqGSIb3DQEBAQUAA4GNADCBiQKBgQCTHgk4F1Fuj1WT3rb97R451KIDLjCwb0dyVD4BQEii7FqUMNjVsfH2oU19Tvkopmt/OVaOI/7khWR/NtiIhXJTekIZYh9Ccop527GwZVlwtvJT4LGtMrcXNK8E6/6i7HCR2UEMbM1AhzEdo9FOwXyjAgw+qWjo1XNpkXIGfqHEeQIDAQAB" . + "MBP/LY+OjgxuKirP/yZa3C1PsePrvGp2b8e+aMBzvSW+Y2WW5DPM7K3mkl9cg0Bh4iIsKJDf95LY82xn5cLzhg/kaAK8Je1VOfUB+bdvfJEa5dwtRe6EvOCWtGDmskUzsEgXr/4coaM+jzILSRMsAAHp6bk85SuQChGbwX2l+Ro=" . + . + "2023-11-08T14:22:04.671Z"^^ . + . + . + . + "Flat RDF triple stream is used in streaming-io.html" . + . + . + . + . diff --git a/integration-tests/src/test/resources/triples/rdf-stax-1-1-2.nt b/integration-tests/src/test/resources/triples/rdf-stax-1-1-2.nt new file mode 100644 index 00000000..ab66f627 --- /dev/null +++ b/integration-tests/src/test/resources/triples/rdf-stax-1-1-2.nt @@ -0,0 +1,297 @@ +# RDF-STaX ontology, version 1.1.2. +# https://w3id.org/stax/1.1.2/ontology + + . +_:n081e1db9176748f38f5806dd94e32572b7 _:n081e1db9176748f38f5806dd94e32572b8 . + . + . + . +_:n081e1db9176748f38f5806dd94e32572b2 . + . + "RDF Stream Taxonomy (RDF-STaX)"@en . + . +_:n081e1db9176748f38f5806dd94e32572b6 . + . +_:n081e1db9176748f38f5806dd94e32572b8 . +_:n081e1db9176748f38f5806dd94e32572b14 _:n081e1db9176748f38f5806dd94e32572b15 . + . + "Grouped RDF stream"@en . + . + . + . + _:n081e1db9176748f38f5806dd94e32572b10 . +_:n081e1db9176748f38f5806dd94e32572b13 _:n081e1db9176748f38f5806dd94e32572b14 . + . + "RDF named graph stream"@en . + "stax" . +_:nf85c28f1008144c2baa8268e0db6aa57b2 "Paweł Szmeja" . +_:n081e1db9176748f38f5806dd94e32572b12 . + . +_:n081e1db9176748f38f5806dd94e32572b8 . + . + . + . + _:nf85c28f1008144c2baa8268e0db6aa57b2 . + . + . + . + . + "can be grouped into"@en . + . + . + . + . + "RDF-STaX"@en . + . +_:n081e1db9176748f38f5806dd94e32572b9 . + . + _:n081e1db9176748f38f5806dd94e32572b1 . + . + "2023-10-22T00:00:00"^^ . + "RDF subject graph stream"@en . + . + . + . + . +_:n081e1db9176748f38f5806dd94e32572b5 . + "A flat RDF stream is an RDF stream whose elements are statements (either RDF triples or RDF quads)."@en . +_:n081e1db9176748f38f5806dd94e32572b5 _:n081e1db9176748f38f5806dd94e32572b6 . + _:n081e1db9176748f38f5806dd94e32572b16 . + . + "Flat RDF stream"@en . + "RDF stream type usage"@en . + . + "For an RDF stream type usage, this property indicates where the stream was used or from where the usage was derived. The value of this property can be anything that makes sense for the desired use case. The value can be for example: the DOI URL of an academic work, URL of a piece of software, IRI of a published stream, IRI of an RDF dataset.\n\nInverse of stax:hasStreamTypeUsage."@en . + . + . + . + "Timestamped RDF named graph stream"@en . + . +_:n081e1db9176748f38f5806dd94e32572b11 . + "A stream of triple statements."@en . + . + . + . + . + . + "An RDF stream is an ordered, potentially infinite sequence of RDF stream elements."@en . + . + . + "RDF stream"@en . + . + "Flat RDF quad stream"@en . + . + "Please cite this ontology according to the instructions here: https://w3id.org/stax/dev/licensing/"@en . + . + "RDF graph"@en . + . + . + . + . + . + "A grouped RDF stream is an RDF stream whose elements are either RDF graphs or RDF datasets."@en . + . + . + . + . + . + "A stream of quad statements."@en . + "RDF quad, as defined by the RDF 1.2 Concepts and Abstract Syntax W3C Working Draft 13 October 2023."@en . + "can be trivially extended into"@en . + "RDF dataset, as defined by the RDF 1.1 Concepts and Abstract Syntax W3C Recommendation."@en . + "Base abstract RDF stream type."@en . + . +_:n081e1db9176748f38f5806dd94e32572b15 . + . + . + "has stream type usage"@en . + "Class for instances of using an RDF stream type, in a program, an academic paper, or elsewhere. This class is suitable for annotating both theoretical uses and practical ones, i.e., real streams or datasets.\n\nInstances of this class should have the stax:hasStreamType property pointing to a concrete stream type. The stax:usedIn property is recommended to indicate where the stream is used – alternatively you can use its inverse (stax:hasStreamTypeUsage). The use of other properties (e.g., rdfs:label, rdfs:comment) is encouraged to give more context about the usage.\n\nNote that \"stream type usage\" is a subjective assertion and instances of this class may be annotated with additional provenance properties to explain who made the assertion. There can be multiple views on what type of stream is in use, depending on the involved actor, processing step, etc."@en . + "An RDF subject graph stream is an RDF graph stream in which every element contains an IRI node (called the subject node) that uniquely identifies the graph in the stream. Every other node in the graph can be reached by traversing triples, starting from the subject node."@en . +_:n081e1db9176748f38f5806dd94e32572b13 . + . + . + . + . + "is in stream type semantic relation with"@en . + "Flat RDF triple stream"@en . + . + . + . + "Class for abstract RDF stream types in the taxonomy. Instances of this class have abstract definitions, i.e., they cannot be used to annotate real streams. They are only intended to be used for reasoning about stream types."@en . + "Indicates that the subject stream type can be grouped into the object.\n\nThe grouping is done by splitting the flat stream of statements into groups, which then can be used to construct elements of the grouped stream. For example, a flat triple stream can be grouped into a graph stream. In this operation, the ordering information within a group is lost."@en . +_:n081e1db9176748f38f5806dd94e32572b3 . + . + . +_:n081e1db9176748f38f5806dd94e32572b16 . +_:nf85c28f1008144c2baa8268e0db6aa57b1 "Piotr Sowiński" . +_:n081e1db9176748f38f5806dd94e32572b10 . + . + . + "Abstract flat RDF stream type."@en . + . + . + . + . + . + . + . + . + "A timestamped named graph is an RDF dataset in which: (1) there is exactly one named RDF graph pair , where G is an RDF graph, and n is the graph name; (2) the default graph includes a timestamp triple , where p is a timestamp predicate that relates t, called the timestamp, and the graph G.\n\nA timestamped RDF named graph stream is an RDF named graph stream in which every element is a timestamped named graph. The elements that share the same timestamp predicate p are ordered by the partial order associated with p."@en . + . + "For an RDF stream type, indicates the base (primitive) type of elements in the stream (e.g., triple, quad, graph, dataset)."@en . + . + . + . + . + . + . + . + "RDF quad"@en . + "is usage of"@en . + . +_:n081e1db9176748f38f5806dd94e32572b16 . + . + . + . +_:n081e1db9176748f38f5806dd94e32572b7 . + . + "A stream of datasets which contain one timestamped, named graph. The definition is based on the draft RSP Data model: https://streamreasoning.org/RSP-QL/Abstract%20Syntax%20and%20Semantics%20Document/"@en . + . +_:n081e1db9176748f38f5806dd94e32572b9 . + . +_:n081e1db9176748f38f5806dd94e32572b1 _:n081e1db9176748f38f5806dd94e32572b2 . + "RDF dataset"@en . + . + "Indicates that the subject stream type can be flattened into the object.\n\nThe flattening is done by enumerating all components of the stream elements in one, flat stream. For example, a graph stream can be flattened into a flat triple stream."@en . +_:n081e1db9176748f38f5806dd94e32572b16 . + "A flat RDF triple stream is a flat RDF stream whose elements are triples."@en . + . + "A flat RDF quad stream is a flat RDF stream whose elements are quads."@en . + "RDF Stream Taxonomy"@en . + "can be flattened into"@en . + . + . +_:n081e1db9176748f38f5806dd94e32572b10 . + "An RDF graph stream is a grouped RDF stream whose elements are unnamed (default) RDF graphs."@en . + "RDF triple"@en . + . + "Base class for RDF stream types. This class should not be used directly – use instead either stax:AbstractRdfStreamType or stax:ConcreteRdfStreamType."@en . + . + . +_:n081e1db9176748f38f5806dd94e32572b12 _:n081e1db9176748f38f5806dd94e32572b13 . + . + _:n081e1db9176748f38f5806dd94e32572b9 . + . + . + . + "A stream of RDF graphs which have a node that uniquely identifies them in the stream."@en . + "has stream type"@en . + . +_:nf85c28f1008144c2baa8268e0db6aa57b2 . + . +_:n081e1db9176748f38f5806dd94e32572b10 . + . + . +_:nf85c28f1008144c2baa8268e0db6aa57b1 "Ostrzyciel" . + . + . + . +_:n081e1db9176748f38f5806dd94e32572b14 . + _:n081e1db9176748f38f5806dd94e32572b7 . + . + "2024-06-30T08:44:43"^^ . +_:n081e1db9176748f38f5806dd94e32572b11 _:n081e1db9176748f38f5806dd94e32572b12 . + . + . + "RDF dataset stream"@en . + . + . + . + . + . + "This property should not be used directly, but as a super-property for all properties denoting a relationship of meaning between RDF stream types."@en . + "RDF element type"@en . +_:n081e1db9176748f38f5806dd94e32572b15 . + _:nf85c28f1008144c2baa8268e0db6aa57b1 . + . + "RDF stream type"@en . + . + . + . + "1.1.2" . + . + . + . +_:nf85c28f1008144c2baa8268e0db6aa57b1 . + . +_:n081e1db9176748f38f5806dd94e32572b6 . + . + . +_:n081e1db9176748f38f5806dd94e32572b3 _:n081e1db9176748f38f5806dd94e32572b4 . + . + . + "RDF graph, as defined by the RDF 1.1 Concepts and Abstract Syntax W3C Recommendation."@en . + . + "RDF triple, as defined by the RDF 1.1 Concepts and Abstract Syntax W3C Recommendation."@en . + "For an RDF stream type usage, this property indicates which stream type is used."@en . +_:n081e1db9176748f38f5806dd94e32572b9 . + "A stream of RDF graphs."@en . + . + . + . + . + "An RDF named graph stream is an RDF dataset stream in which every element has exactly one named RDF graph pair , where G is an RDF graph, and n is the graph name. Apart from graph G, the dataset may contain any number of triples in the default graph."@en . + . + "RDF-STaX is an OWL 2 DL ontology that enables describing the types of RDF streams and defines relations between them."@en . + _:n081e1db9176748f38f5806dd94e32572b5 . + . + . + . + . + . + . + "Abstract grouped RDF stream type."@en . + . + "RDF graph stream"@en . + . + "Concrete RDF stream type"@en . + . + . +_:n081e1db9176748f38f5806dd94e32572b4 . +_:n081e1db9176748f38f5806dd94e32572b4 . + . + "Indicates that the subject stream type that uses triples or graphs can be trivially extended into the object type that uses quads or datasets.\n\nThe extension is done by (in case of flat RDF streams) adding a fourth component, corresponding to the default graph. In case of grouped RDF streams, the contents of the graph are placed explicitly in the default graph."@en . + "An RDF dataset stream is a grouped RDF stream whose elements are RDF datasets."@en . + . + . + "Class for the concrete RDF stream types in the taxonomy. Instances of this class have concrete definitions, and they can be used to annotate real streams."@en . + _:n081e1db9176748f38f5806dd94e32572b11 . + "2023-10-23T00:00:00"^^ . +_:n081e1db9176748f38f5806dd94e32572b2 . + . + . + "Inverse of stax:isUsageOf – indicates that the subject is related to a usage of an RDF stream type.\n\nThe subject for this property can be for example a published stream on the Web (e.g., vocals:RDFStream) or a scientific publication that discusses a usage of an RDF stream type."@en . + . + "A stream of datasets which have one named graph."@en . + . + . + . + . + . + "Class for base types of elements in RDF streams. There are four instances of this class (triple, quad, graph, dataset) and they should not be further specialized. The instances of this class do NOT form a taxonomical structure."@en . + _:n081e1db9176748f38f5806dd94e32572b3 . + . + "A stream of RDF datasets."@en . +_:n081e1db9176748f38f5806dd94e32572b1 . + . + "has element type"@en . + "Abstract RDF stream type"@en . + . + . + . + . + . + . + . + . + . diff --git a/integration-tests/src/test/resources/triples/riverbench-assist-iot-weather-1-0-2.nt b/integration-tests/src/test/resources/triples/riverbench-assist-iot-weather-1-0-2.nt new file mode 100644 index 00000000..3705c175 --- /dev/null +++ b/integration-tests/src/test/resources/triples/riverbench-assist-iot-weather-1-0-2.nt @@ -0,0 +1,573 @@ +# Metadata for RiverBench dataset assist-iot-weather in version 1.0.2. +# https://w3id.org/riverbench/datasets/assist-iot-weather/1.0.2 + + "application/gzip" . + "stream-100k" . + "text/turtle" . + _:B664486917573831cda977ead05f6be19 . + "application/tar" . + "stream_100K.tar.gz" . + . + "24552337"^^ . + "100000"^^ . + . + . + "100K elements stream distribution" . + . + _:Be595c2fd8bde513e4a861e5f1ae257c6 . + . + "3"^^ . + _:Bb28885930f43f96e972a0d6b1b0e12b2 . + . + "10K elements flat distribution" . + . + "flat-10k" . + . + _:Bfc36498e2c4aa48e6c3c1d7d556d7130 . + . + _:Be425f6d05b487f5373d982fb02308da3 . + . + "application/gzip" . + . + "4942582"^^ . + . + "flat_10K.nt.gz" . + _:B93196fa21d0f2b1896d6f51b06bd1c32 . + "8"^^ . + "10000"^^ . + "application/n-triples" . +_:B46d20f87f5d4d4a688aac9f712099596 . +_:B46d20f87f5d4d4a688aac9f712099596 . +_:B46d20f87f5d4d4a688aac9f712099596 "57baa3e5ce01743027fad241fda33e71ccd6e0dc" . +_:B46d20f87f5d4d4a688aac9f712099596 "2"^^ . +_:Ba53f05fbb546ac12a847931fb01a7a66 . +_:Ba53f05fbb546ac12a847931fb01a7a66 "7"^^ . +_:Ba53f05fbb546ac12a847931fb01a7a66 "30"^^ . +_:Ba53f05fbb546ac12a847931fb01a7a66 "30.0"^^ . +_:Ba53f05fbb546ac12a847931fb01a7a66 "30"^^ . +_:Ba53f05fbb546ac12a847931fb01a7a66 "0.0"^^ . +_:Ba53f05fbb546ac12a847931fb01a7a66 "21038340"^^ . +_:Ba53f05fbb546ac12a847931fb01a7a66 "12622946"^^ . +_:B88cc3f582342425cce7a3d2828bef555 . +_:B88cc3f582342425cce7a3d2828bef555 "5"^^ . +_:B88cc3f582342425cce7a3d2828bef555 "0"^^ . +_:B88cc3f582342425cce7a3d2828bef555 "0.0"^^ . +_:B88cc3f582342425cce7a3d2828bef555 "0"^^ . +_:B88cc3f582342425cce7a3d2828bef555 "0.0"^^ . +_:B88cc3f582342425cce7a3d2828bef555 "0"^^ . +_:B88cc3f582342425cce7a3d2828bef555 "0"^^ . +_:Bb63b59ad7e33abf75c57154cffa76ee0 . +_:Bb63b59ad7e33abf75c57154cffa76ee0 "4"^^ . +_:Bb63b59ad7e33abf75c57154cffa76ee0 "11"^^ . +_:Bb63b59ad7e33abf75c57154cffa76ee0 "10.0737"^^ . +_:Bb63b59ad7e33abf75c57154cffa76ee0 "8"^^ . +_:Bb63b59ad7e33abf75c57154cffa76ee0 "0.604705143024259"^^ . +_:Bb63b59ad7e33abf75c57154cffa76ee0 "100737"^^ . +_:Bb63b59ad7e33abf75c57154cffa76ee0 "10799"^^ . +_:Bfbddb2ae40199684225c6d6eddb8b600 . +_:Bfbddb2ae40199684225c6d6eddb8b600 . +_:Bfbddb2ae40199684225c6d6eddb8b600 "c41a0179682b16fdc2ec40563ffe4c86695e1a23" . +_:Bfbddb2ae40199684225c6d6eddb8b600 "2"^^ . +_:B03582170d6a99039a2a0b58fd83a8936 . +_:B03582170d6a99039a2a0b58fd83a8936 "1"^^ . +_:B03582170d6a99039a2a0b58fd83a8936 "0"^^ . +_:B03582170d6a99039a2a0b58fd83a8936 "0.0"^^ . +_:B03582170d6a99039a2a0b58fd83a8936 "0"^^ . +_:B03582170d6a99039a2a0b58fd83a8936 "0.0"^^ . +_:B03582170d6a99039a2a0b58fd83a8936 "0"^^ . +_:B1880b2376f4c46cae40199cb82a42ebd . +_:B1880b2376f4c46cae40199cb82a42ebd . +_:B1880b2376f4c46cae40199cb82a42ebd "b9d2d15b8130188600f304fc1524eaca4ce5ea32" . +_:B1880b2376f4c46cae40199cb82a42ebd "2"^^ . +_:B2d76c5089ca63f369cf6a8de2774666c . +_:B2d76c5089ca63f369cf6a8de2774666c . +_:B2d76c5089ca63f369cf6a8de2774666c "a1161f75a859d71e264d53c61660dfa06c68c401" . +_:B2d76c5089ca63f369cf6a8de2774666c "2"^^ . + "Full flat distribution" . + _:Bb79d17974c2d667d0aa856a982ff9b87 . + . + . + "346228347"^^ . + "flat-full" . + _:Bfc36498e2c4aa48e6c3c1d7d556d7130 . + "application/n-triples" . + . + "flat_full.nt.gz" . + "701278"^^ . + . + "application/gzip" . + "2"^^ . + _:Bf8f4cd5231598957b9536056b04b7348 . + . + . +_:Bc650c5f368032f6b5530e7998e3ad241 "Each stream element corresponds to one set of measurements from the weather station. Data was collected every 10 seconds."@en . +_:Bc650c5f368032f6b5530e7998e3ad241 . +_:Bc650c5f368032f6b5530e7998e3ad241 . + . + "Full Jelly distribution" . + "106144959"^^ . + . + . + _:Bfc36498e2c4aa48e6c3c1d7d556d7130 . + "application/gzip" . + . + "1"^^ . + "jelly_full.jelly.gz" . + _:Be595c2fd8bde513e4a861e5f1ae257c6 . + _:Bfbddb2ae40199684225c6d6eddb8b600 . + "application/x-jelly-rdf" . + "jelly-full" . + . + . + _:B6cda81647b53d4d0c033056f3e696e1c . + "701278"^^ . +_:Ba39b7026bc752b20360885ad1f1fe065 . +_:Ba39b7026bc752b20360885ad1f1fe065 . +_:Ba39b7026bc752b20360885ad1f1fe065 "9c3d2ff9c03f8e6a1bbb73b165bf714da486b11c" . +_:Ba39b7026bc752b20360885ad1f1fe065 "2"^^ . + _:Be3bdfd8866bb869039c4aa80594fc8a8 . + _:B4b219b8b5af9103067a5394db91c98c1 . + _:B9a3176115393205a06592aad82800d3c . + _:B4dc5fc7bdb1d77e62865b238d01045c0 . + _:Bb63b59ad7e33abf75c57154cffa76ee0 . + "Statistics for 10K distributions" . + _:Bd441c0ce516e4c6d7b9a89e7a824c299 . + _:B524d294e65cd6b90036c070cdcf692f9 . + "2"^^ . + . + _:B03582170d6a99039a2a0b58fd83a8936 . + _:B88cc3f582342425cce7a3d2828bef555 . + _:B1a78fb3be9770c70e557990636b356ad . + _:Bf9f25c68de438909f712d83ff53cf66e . + _:B6125ea10e838154a0db09d352ba05709 . +_:B41dd5666bd6eba8f4ff8db87426ed8a8 . +_:B41dd5666bd6eba8f4ff8db87426ed8a8 "7"^^ . +_:B41dd5666bd6eba8f4ff8db87426ed8a8 "30"^^ . +_:B41dd5666bd6eba8f4ff8db87426ed8a8 "30.0"^^ . +_:B41dd5666bd6eba8f4ff8db87426ed8a8 "30"^^ . +_:B41dd5666bd6eba8f4ff8db87426ed8a8 "0.0"^^ . +_:B41dd5666bd6eba8f4ff8db87426ed8a8 "3000000"^^ . +_:B41dd5666bd6eba8f4ff8db87426ed8a8 "1799560"^^ . +_:B524d294e65cd6b90036c070cdcf692f9 . +_:B524d294e65cd6b90036c070cdcf692f9 "7"^^ . +_:B524d294e65cd6b90036c070cdcf692f9 "30"^^ . +_:B524d294e65cd6b90036c070cdcf692f9 "30.0"^^ . +_:B524d294e65cd6b90036c070cdcf692f9 "30"^^ . +_:B524d294e65cd6b90036c070cdcf692f9 "0.0"^^ . +_:B524d294e65cd6b90036c070cdcf692f9 "300000"^^ . +_:B524d294e65cd6b90036c070cdcf692f9 "179997"^^ . +_:Ba756d02251a188792751ddaaba1c2daf . +_:Ba756d02251a188792751ddaaba1c2daf . +_:Ba756d02251a188792751ddaaba1c2daf "4cb2659bdddb80842759af2897ea8577c2516fa1" . +_:Ba756d02251a188792751ddaaba1c2daf "2"^^ . + . + "5"^^ . + "49356248"^^ . + . + "100K elements flat distribution" . + _:B502134f75dd724dcc61f65993718deb2 . + "100000"^^ . + _:B2d76c5089ca63f369cf6a8de2774666c . + "flat-100k" . + "flat_100K.nt.gz" . + . + . + . + "application/n-triples" . + "application/gzip" . + . + _:Bfc36498e2c4aa48e6c3c1d7d556d7130 . +_:Bb28885930f43f96e972a0d6b1b0e12b2 . +_:Bb28885930f43f96e972a0d6b1b0e12b2 . +_:Bb28885930f43f96e972a0d6b1b0e12b2 "508800d22b1ca55613a9ec70d722ed82" . +_:Bb28885930f43f96e972a0d6b1b0e12b2 "1"^^ . +_:B51c20b704a25efcd67128098a1081337 "2"^^ . +_:B51c20b704a25efcd67128098a1081337 "This project has received funding from the European Union’s Horizon 2020 research and innovation programme under grant agreement No 957258." . +_:B51c20b704a25efcd67128098a1081337 . +_:B51c20b704a25efcd67128098a1081337 "ASSIST-IoT Horizon 2020 project" . +_:B34496c3e5cf7cbbc273bdd387c8e26c9 . +_:B34496c3e5cf7cbbc273bdd387c8e26c9 "10"^^ . +_:B34496c3e5cf7cbbc273bdd387c8e26c9 "1"^^ . +_:B34496c3e5cf7cbbc273bdd387c8e26c9 "1.0"^^ . +_:B34496c3e5cf7cbbc273bdd387c8e26c9 "1"^^ . +_:B34496c3e5cf7cbbc273bdd387c8e26c9 "0.0"^^ . +_:B34496c3e5cf7cbbc273bdd387c8e26c9 "100000"^^ . +_:B34496c3e5cf7cbbc273bdd387c8e26c9 "1"^^ . + _:Be595c2fd8bde513e4a861e5f1ae257c6 . + "application/x-jelly-rdf" . + "15129251"^^ . + . + . + _:B4d32a63bd14a2f2a01af562484911a6d . + . + . + _:Bfc36498e2c4aa48e6c3c1d7d556d7130 . + "application/gzip" . + _:B46d20f87f5d4d4a688aac9f712099596 . + "100K elements Jelly distribution" . + . + "100000"^^ . + "jelly-100k" . + . + "4"^^ . + "jelly_100K.jelly.gz" . +_:Bc81a35833d5f7f7e17003adf082e7c19 . +_:Bc81a35833d5f7f7e17003adf082e7c19 "8"^^ . +_:Bc81a35833d5f7f7e17003adf082e7c19 "12"^^ . +_:Bc81a35833d5f7f7e17003adf082e7c19 "12.0"^^ . +_:Bc81a35833d5f7f7e17003adf082e7c19 "12"^^ . +_:Bc81a35833d5f7f7e17003adf082e7c19 "0.0"^^ . +_:Bc81a35833d5f7f7e17003adf082e7c19 "1200000"^^ . +_:Bc81a35833d5f7f7e17003adf082e7c19 "12"^^ . +_:B86edaa9a4cf717c6a8545ed28703c95b . +_:B86edaa9a4cf717c6a8545ed28703c95b "3"^^ . +_:B86edaa9a4cf717c6a8545ed28703c95b "2"^^ . +_:B86edaa9a4cf717c6a8545ed28703c95b "2.0"^^ . +_:B86edaa9a4cf717c6a8545ed28703c95b "2"^^ . +_:B86edaa9a4cf717c6a8545ed28703c95b "0.0"^^ . +_:B86edaa9a4cf717c6a8545ed28703c95b "1402556"^^ . +_:B86edaa9a4cf717c6a8545ed28703c95b "2"^^ . + "Statistics for full distributions" . + _:Be3bdfd8866bb869039c4aa80594fc8a8 . + _:B03582170d6a99039a2a0b58fd83a8936 . + _:Bdd4e1dc0c6ff7854cc8b0bc7e54d14bd . + _:Ba12620e685f02ab8d908f90d127b024e . + _:Bc8bf8cae76203e466ff0a4d30db7230b . + _:Ba7d1ba67b8a0e721d952811e17c80e64 . + . + _:B88cc3f582342425cce7a3d2828bef555 . + _:B0a51d58d488ee977dadf23bfcc37c565 . + _:B690dfeeaed9be04a99062a4b4ef91d91 . + _:B65f69829d1cfd182c6cf13a277f118f4 . + "0"^^ . + _:B86edaa9a4cf717c6a8545ed28703c95b . + _:Ba53f05fbb546ac12a847931fb01a7a66 . +_:Bfc36498e2c4aa48e6c3c1d7d556d7130 . +_:Bfc36498e2c4aa48e6c3c1d7d556d7130 "The dataset can be viewed as a flattened stream of triples."@en . +_:Bfc36498e2c4aa48e6c3c1d7d556d7130 . +_:B502134f75dd724dcc61f65993718deb2 . +_:B502134f75dd724dcc61f65993718deb2 . +_:B502134f75dd724dcc61f65993718deb2 "fe0567bd37f2acb357fb513c15e467b6" . +_:B502134f75dd724dcc61f65993718deb2 "1"^^ . +_:B1a78fb3be9770c70e557990636b356ad . +_:B1a78fb3be9770c70e557990636b356ad "3"^^ . +_:B1a78fb3be9770c70e557990636b356ad "2"^^ . +_:B1a78fb3be9770c70e557990636b356ad "2.0"^^ . +_:B1a78fb3be9770c70e557990636b356ad "2"^^ . +_:B1a78fb3be9770c70e557990636b356ad "0.0"^^ . +_:B1a78fb3be9770c70e557990636b356ad "20000"^^ . +_:B1a78fb3be9770c70e557990636b356ad "2"^^ . +_:Bdd4e1dc0c6ff7854cc8b0bc7e54d14bd . +_:Bdd4e1dc0c6ff7854cc8b0bc7e54d14bd "9"^^ . +_:Bdd4e1dc0c6ff7854cc8b0bc7e54d14bd "57"^^ . +_:Bdd4e1dc0c6ff7854cc8b0bc7e54d14bd "56.14361494300406"^^ . +_:Bdd4e1dc0c6ff7854cc8b0bc7e54d14bd "54"^^ . +_:Bdd4e1dc0c6ff7854cc8b0bc7e54d14bd "0.6936991601507121"^^ . +_:Bdd4e1dc0c6ff7854cc8b0bc7e54d14bd "39372282"^^ . +_:Bdd4e1dc0c6ff7854cc8b0bc7e54d14bd "7015898"^^ . + . + _:B48d6f3a887828c62591dff85479945ff . + _:B41dd5666bd6eba8f4ff8db87426ed8a8 . + _:Bcecfd0ef18a46b4696a44a4bc8367262 . + "1"^^ . + "Statistics for 100K distributions" . + _:Bc81a35833d5f7f7e17003adf082e7c19 . + _:B88cc3f582342425cce7a3d2828bef555 . + _:B4aa7105b4a681fb7b0aa3679626f37bf . + _:B321bddb1c2cae8658aee7711ccbcdce4 . + _:B601db6dcc1b0d20e71dd0342a63f6a81 . + _:Bf5dd0725532ad1936314170c4988a9b9 . + _:B03582170d6a99039a2a0b58fd83a8936 . + _:Be3bdfd8866bb869039c4aa80594fc8a8 . + _:B34496c3e5cf7cbbc273bdd387c8e26c9 . +_:Bf5dd0725532ad1936314170c4988a9b9 . +_:Bf5dd0725532ad1936314170c4988a9b9 "4"^^ . +_:Bf5dd0725532ad1936314170c4988a9b9 "11"^^ . +_:Bf5dd0725532ad1936314170c4988a9b9 "10.05786"^^ . +_:Bf5dd0725532ad1936314170c4988a9b9 "8"^^ . +_:Bf5dd0725532ad1936314170c4988a9b9 "0.6091077247909473"^^ . +_:Bf5dd0725532ad1936314170c4988a9b9 "1005786"^^ . +_:Bf5dd0725532ad1936314170c4988a9b9 "102022"^^ . +_:B690dfeeaed9be04a99062a4b4ef91d91 . +_:B690dfeeaed9be04a99062a4b4ef91d91 "11"^^ . +_:B690dfeeaed9be04a99062a4b4ef91d91 "115"^^ . +_:B690dfeeaed9be04a99062a4b4ef91d91 "115.0"^^ . +_:B690dfeeaed9be04a99062a4b4ef91d91 "115"^^ . +_:B690dfeeaed9be04a99062a4b4ef91d91 "0.0"^^ . +_:B690dfeeaed9be04a99062a4b4ef91d91 "80646970"^^ . +_:B4dc5fc7bdb1d77e62865b238d01045c0 . +_:B4dc5fc7bdb1d77e62865b238d01045c0 "11"^^ . +_:B4dc5fc7bdb1d77e62865b238d01045c0 "115"^^ . +_:B4dc5fc7bdb1d77e62865b238d01045c0 "115.0"^^ . +_:B4dc5fc7bdb1d77e62865b238d01045c0 "115"^^ . +_:B4dc5fc7bdb1d77e62865b238d01045c0 "0.0"^^ . +_:B4dc5fc7bdb1d77e62865b238d01045c0 "1150000"^^ . +_:B0a51d58d488ee977dadf23bfcc37c565 . +_:B0a51d58d488ee977dadf23bfcc37c565 "0"^^ . +_:B0a51d58d488ee977dadf23bfcc37c565 "65"^^ . +_:B0a51d58d488ee977dadf23bfcc37c565 "65.0"^^ . +_:B0a51d58d488ee977dadf23bfcc37c565 "65"^^ . +_:B0a51d58d488ee977dadf23bfcc37c565 "0.0"^^ . +_:B0a51d58d488ee977dadf23bfcc37c565 "45583070"^^ . +_:B0a51d58d488ee977dadf23bfcc37c565 "12624089"^^ . +_:Bf9f25c68de438909f712d83ff53cf66e . +_:Bf9f25c68de438909f712d83ff53cf66e "10"^^ . +_:Bf9f25c68de438909f712d83ff53cf66e "1"^^ . +_:Bf9f25c68de438909f712d83ff53cf66e "1.0"^^ . +_:Bf9f25c68de438909f712d83ff53cf66e "1"^^ . +_:Bf9f25c68de438909f712d83ff53cf66e "0.0"^^ . +_:Bf9f25c68de438909f712d83ff53cf66e "10000"^^ . +_:Bf9f25c68de438909f712d83ff53cf66e "1"^^ . +_:Be595c2fd8bde513e4a861e5f1ae257c6 . +_:Be595c2fd8bde513e4a861e5f1ae257c6 "The dataset can be viewed as a stream of graphs. Each graph corresponds to one set of observations from the weather station's sensors."@en . +_:Be595c2fd8bde513e4a861e5f1ae257c6 . +_:B4b219b8b5af9103067a5394db91c98c1 . +_:B4b219b8b5af9103067a5394db91c98c1 "9"^^ . +_:B4b219b8b5af9103067a5394db91c98c1 "57"^^ . +_:B4b219b8b5af9103067a5394db91c98c1 "56.0737"^^ . +_:B4b219b8b5af9103067a5394db91c98c1 "54"^^ . +_:B4b219b8b5af9103067a5394db91c98c1 "0.604705143024118"^^ . +_:B4b219b8b5af9103067a5394db91c98c1 "560737"^^ . +_:B4b219b8b5af9103067a5394db91c98c1 "100845"^^ . +_:Be3bdfd8866bb869039c4aa80594fc8a8 . +_:Be3bdfd8866bb869039c4aa80594fc8a8 "6"^^ . +_:Be3bdfd8866bb869039c4aa80594fc8a8 "0"^^ . +_:Be3bdfd8866bb869039c4aa80594fc8a8 "0.0"^^ . +_:Be3bdfd8866bb869039c4aa80594fc8a8 "0"^^ . +_:Be3bdfd8866bb869039c4aa80594fc8a8 "0.0"^^ . +_:Be3bdfd8866bb869039c4aa80594fc8a8 "0"^^ . + "application/x-jelly-rdf" . + "10000"^^ . + . + . + _:Be595c2fd8bde513e4a861e5f1ae257c6 . + "1519673"^^ . + . + . + _:Ba756d02251a188792751ddaaba1c2daf . + _:Bcb1f411cea7fc4fe7d9aaff6a68c6dc3 . + "jelly-10k" . + _:Bfc36498e2c4aa48e6c3c1d7d556d7130 . + . + "7"^^ . + "application/gzip" . + "jelly_10K.jelly.gz" . + "10K elements Jelly distribution" . + . +_:Ba7d1ba67b8a0e721d952811e17c80e64 . +_:Ba7d1ba67b8a0e721d952811e17c80e64 "10"^^ . +_:Ba7d1ba67b8a0e721d952811e17c80e64 "1"^^ . +_:Ba7d1ba67b8a0e721d952811e17c80e64 "1.0"^^ . +_:Ba7d1ba67b8a0e721d952811e17c80e64 "1"^^ . +_:Ba7d1ba67b8a0e721d952811e17c80e64 "0.0"^^ . +_:Ba7d1ba67b8a0e721d952811e17c80e64 "701278"^^ . +_:Ba7d1ba67b8a0e721d952811e17c80e64 "1"^^ . +_:B65f69829d1cfd182c6cf13a277f118f4 . +_:B65f69829d1cfd182c6cf13a277f118f4 "4"^^ . +_:B65f69829d1cfd182c6cf13a277f118f4 "11"^^ . +_:B65f69829d1cfd182c6cf13a277f118f4 "10.143614943004058"^^ . +_:B65f69829d1cfd182c6cf13a277f118f4 "8"^^ . +_:B65f69829d1cfd182c6cf13a277f118f4 "0.6936991601506506"^^ . +_:B65f69829d1cfd182c6cf13a277f118f4 "7113494"^^ . +_:B65f69829d1cfd182c6cf13a277f118f4 "704200"^^ . +_:B6cda81647b53d4d0c033056f3e696e1c . +_:B6cda81647b53d4d0c033056f3e696e1c . +_:B6cda81647b53d4d0c033056f3e696e1c "aa18479965cf37ccd4f195095b8097ce" . +_:B6cda81647b53d4d0c033056f3e696e1c "1"^^ . +_:Bf8f4cd5231598957b9536056b04b7348 . +_:Bf8f4cd5231598957b9536056b04b7348 . +_:Bf8f4cd5231598957b9536056b04b7348 "5e0770a549c4f4e7ff4e5162a88c6884" . +_:Bf8f4cd5231598957b9536056b04b7348 "1"^^ . +_:Ba12620e685f02ab8d908f90d127b024e . +_:Ba12620e685f02ab8d908f90d127b024e "8"^^ . +_:Ba12620e685f02ab8d908f90d127b024e "12"^^ . +_:Ba12620e685f02ab8d908f90d127b024e "12.0"^^ . +_:Ba12620e685f02ab8d908f90d127b024e "12"^^ . +_:Ba12620e685f02ab8d908f90d127b024e "0.0"^^ . +_:Ba12620e685f02ab8d908f90d127b024e "8415336"^^ . +_:Ba12620e685f02ab8d908f90d127b024e "12"^^ . +_:Bbbd23de419c73d1acaa5c21f8e6a9431 . +_:Bbbd23de419c73d1acaa5c21f8e6a9431 . +_:Bbbd23de419c73d1acaa5c21f8e6a9431 "b539bfa613f02a10b0c0043cc32b9289" . +_:Bbbd23de419c73d1acaa5c21f8e6a9431 "1"^^ . +_:Bcecfd0ef18a46b4696a44a4bc8367262 . +_:Bcecfd0ef18a46b4696a44a4bc8367262 "11"^^ . +_:Bcecfd0ef18a46b4696a44a4bc8367262 "115"^^ . +_:Bcecfd0ef18a46b4696a44a4bc8367262 "115.0"^^ . +_:Bcecfd0ef18a46b4696a44a4bc8367262 "115"^^ . +_:Bcecfd0ef18a46b4696a44a4bc8367262 "0.0"^^ . +_:Bcecfd0ef18a46b4696a44a4bc8367262 "11500000"^^ . +_:B3d330d520433b744068cddb8a8ed755d "1"^^ . +_:B3d330d520433b744068cddb8a8ed755d . +_:B3d330d520433b744068cddb8a8ed755d . +_:B3d330d520433b744068cddb8a8ed755d "Ostrzyciel" . +_:B3d330d520433b744068cddb8a8ed755d "Piotr Sowiński" . +_:B664486917573831cda977ead05f6be19 . +_:B664486917573831cda977ead05f6be19 . +_:B664486917573831cda977ead05f6be19 "9b9e7af790ca75c3f9c763166892d4bc9abcd095" . +_:B664486917573831cda977ead05f6be19 "2"^^ . +_:Bcb1f411cea7fc4fe7d9aaff6a68c6dc3 . +_:Bcb1f411cea7fc4fe7d9aaff6a68c6dc3 . +_:Bcb1f411cea7fc4fe7d9aaff6a68c6dc3 "8c140c007abf0e3f703c3a0677c680fe" . +_:Bcb1f411cea7fc4fe7d9aaff6a68c6dc3 "1"^^ . +_:Bc8bf8cae76203e466ff0a4d30db7230b . +_:Bc8bf8cae76203e466ff0a4d30db7230b "2"^^ . +_:Bc8bf8cae76203e466ff0a4d30db7230b "13"^^ . +_:Bc8bf8cae76203e466ff0a4d30db7230b "12.143614943004058"^^ . +_:Bc8bf8cae76203e466ff0a4d30db7230b "10"^^ . +_:Bc8bf8cae76203e466ff0a4d30db7230b "0.6936991601506506"^^ . +_:Bc8bf8cae76203e466ff0a4d30db7230b "8516050"^^ . +_:Bc8bf8cae76203e466ff0a4d30db7230b "704202"^^ . +_:B4d32a63bd14a2f2a01af562484911a6d . +_:B4d32a63bd14a2f2a01af562484911a6d . +_:B4d32a63bd14a2f2a01af562484911a6d "2fb33c044954aeab1f20ab7d94890ff6" . +_:B4d32a63bd14a2f2a01af562484911a6d "1"^^ . +_:Bd441c0ce516e4c6d7b9a89e7a824c299 . +_:Bd441c0ce516e4c6d7b9a89e7a824c299 "0"^^ . +_:Bd441c0ce516e4c6d7b9a89e7a824c299 "65"^^ . +_:Bd441c0ce516e4c6d7b9a89e7a824c299 "65.0"^^ . +_:Bd441c0ce516e4c6d7b9a89e7a824c299 "65"^^ . +_:Bd441c0ce516e4c6d7b9a89e7a824c299 "0.0"^^ . +_:Bd441c0ce516e4c6d7b9a89e7a824c299 "650000"^^ . +_:Bd441c0ce516e4c6d7b9a89e7a824c299 "180046"^^ . +_:B321bddb1c2cae8658aee7711ccbcdce4 . +_:B321bddb1c2cae8658aee7711ccbcdce4 "2"^^ . +_:B321bddb1c2cae8658aee7711ccbcdce4 "13"^^ . +_:B321bddb1c2cae8658aee7711ccbcdce4 "12.05786"^^ . +_:B321bddb1c2cae8658aee7711ccbcdce4 "10"^^ . +_:B321bddb1c2cae8658aee7711ccbcdce4 "0.609107724790959"^^ . +_:B321bddb1c2cae8658aee7711ccbcdce4 "1205786"^^ . +_:B321bddb1c2cae8658aee7711ccbcdce4 "102024"^^ . +_:B9a3176115393205a06592aad82800d3c . +_:B9a3176115393205a06592aad82800d3c "8"^^ . +_:B9a3176115393205a06592aad82800d3c "12"^^ . +_:B9a3176115393205a06592aad82800d3c "12.0"^^ . +_:B9a3176115393205a06592aad82800d3c "12"^^ . +_:B9a3176115393205a06592aad82800d3c "0.0"^^ . +_:B9a3176115393205a06592aad82800d3c "120000"^^ . +_:B9a3176115393205a06592aad82800d3c "12"^^ . +_:B601db6dcc1b0d20e71dd0342a63f6a81 . +_:B601db6dcc1b0d20e71dd0342a63f6a81 "0"^^ . +_:B601db6dcc1b0d20e71dd0342a63f6a81 "65"^^ . +_:B601db6dcc1b0d20e71dd0342a63f6a81 "65.0"^^ . +_:B601db6dcc1b0d20e71dd0342a63f6a81 "65"^^ . +_:B601db6dcc1b0d20e71dd0342a63f6a81 "0.0"^^ . +_:B601db6dcc1b0d20e71dd0342a63f6a81 "6500000"^^ . +_:B601db6dcc1b0d20e71dd0342a63f6a81 "1800107"^^ . +_:B93196fa21d0f2b1896d6f51b06bd1c32 . +_:B93196fa21d0f2b1896d6f51b06bd1c32 . +_:B93196fa21d0f2b1896d6f51b06bd1c32 "a27d5cb58d4642b4cf9680f5fa719127" . +_:B93196fa21d0f2b1896d6f51b06bd1c32 "1"^^ . +_:Bbc9d95fba2e0aebf35ee06dae0d50e75 . +_:Bbc9d95fba2e0aebf35ee06dae0d50e75 . +_:Bbc9d95fba2e0aebf35ee06dae0d50e75 "d10a280193620fff177df6dbbbfe09d9" . +_:Bbc9d95fba2e0aebf35ee06dae0d50e75 "1"^^ . +_:B6125ea10e838154a0db09d352ba05709 . +_:B6125ea10e838154a0db09d352ba05709 "2"^^ . +_:B6125ea10e838154a0db09d352ba05709 "13"^^ . +_:B6125ea10e838154a0db09d352ba05709 "12.0737"^^ . +_:B6125ea10e838154a0db09d352ba05709 "10"^^ . +_:B6125ea10e838154a0db09d352ba05709 "0.604705143024259"^^ . +_:B6125ea10e838154a0db09d352ba05709 "120737"^^ . +_:B6125ea10e838154a0db09d352ba05709 "10801"^^ . +_:Be425f6d05b487f5373d982fb02308da3 . +_:Be425f6d05b487f5373d982fb02308da3 . +_:Be425f6d05b487f5373d982fb02308da3 "fff5a3be40efff691b0247c9696c0a653bc39351" . +_:Be425f6d05b487f5373d982fb02308da3 "2"^^ . +_:Bb79d17974c2d667d0aa856a982ff9b87 . +_:Bb79d17974c2d667d0aa856a982ff9b87 . +_:Bb79d17974c2d667d0aa856a982ff9b87 "acab677e44c7c841e8c3137330865eaf6b1201b9" . +_:Bb79d17974c2d667d0aa856a982ff9b87 "2"^^ . + _:Be595c2fd8bde513e4a861e5f1ae257c6 . + . + "application/gzip" . + "text/turtle" . + "stream_full.tar.gz" . + . + "172119892"^^ . + . + "701278"^^ . + "0"^^ . + . + . + _:B1880b2376f4c46cae40199cb82a42ebd . + "stream-full" . + _:Bbbd23de419c73d1acaa5c21f8e6a9431 . + "Full stream distribution" . + "application/tar" . + . +_:B48d6f3a887828c62591dff85479945ff . +_:B48d6f3a887828c62591dff85479945ff "3"^^ . +_:B48d6f3a887828c62591dff85479945ff "2"^^ . +_:B48d6f3a887828c62591dff85479945ff "2.0"^^ . +_:B48d6f3a887828c62591dff85479945ff "2"^^ . +_:B48d6f3a887828c62591dff85479945ff "0.0"^^ . +_:B48d6f3a887828c62591dff85479945ff "200000"^^ . +_:B48d6f3a887828c62591dff85479945ff "2"^^ . + "1.0.2" . + . + . + . + . + . + . + . + . + . + . + "true"^^ . + "true"^^ . + . + . + "assist-iot-weather" . + . + "2023-05-04"^^ . + . + _:B51c20b704a25efcd67128098a1081337 . + . + _:B3d330d520433b744068cddb8a8ed755d . + "false"^^ . + . + . + "This is a timestamped stream of weather data collected with a Davis Vantage Pro 2 weather station installed on the building of the [Systems Research Institute, Polish Academy of Sciences](https://www.ibspan.waw.pl/en/home/). The data was collected during the [ASSIST-IoT Horizon 2020 project](https://assist-iot.eu/). The station measured several different weather parameters and transmitted them in real time at regular intervals. The measurements have rich annotations with the [SOSA/SSN](https://www.w3.org/TR/vocab-ssn/) and [OM 2.0](http://www.ontology-of-units-of-measure.org/page/om-2) ontologies. The stream is very regular and the elements only differ by numeric values and timestamps.\n \nThe dataset is a real application of RDF streaming (originally streamed over MQTT), with much richer annotations than [citypulse-traffic](https://w3id.org/riverbench/datasets/citypulse-traffic). On the other hand, it is perfectly regular, with no differences in structure between stream elements."@en . + _:Bfc36498e2c4aa48e6c3c1d7d556d7130 . + . + _:Be595c2fd8bde513e4a861e5f1ae257c6 . + "false"^^ . + "PT10S"^^ . + "false"^^ . + . + "2024-06-07"^^ . + . + _:Bc650c5f368032f6b5530e7998e3ad241 . + "701278"^^ . + "en" . + . + . + "ASSIST-IoT weather (triples variant)"@en . + _:Ba39b7026bc752b20360885ad1f1fe065 . + _:Be595c2fd8bde513e4a861e5f1ae257c6 . + "stream_10K.tar.gz" . + "application/tar" . + . + "6"^^ . + "2461039"^^ . + . + "application/gzip" . + . + . + "10K elements stream distribution" . + . + . + _:Bbc9d95fba2e0aebf35ee06dae0d50e75 . + "text/turtle" . + "stream-10k" . + "10000"^^ . +_:B4aa7105b4a681fb7b0aa3679626f37bf . +_:B4aa7105b4a681fb7b0aa3679626f37bf "9"^^ . +_:B4aa7105b4a681fb7b0aa3679626f37bf "57"^^ . +_:B4aa7105b4a681fb7b0aa3679626f37bf "56.05786"^^ . +_:B4aa7105b4a681fb7b0aa3679626f37bf "54"^^ . +_:B4aa7105b4a681fb7b0aa3679626f37bf "0.6091077247910989"^^ . +_:B4aa7105b4a681fb7b0aa3679626f37bf "5605786"^^ . +_:B4aa7105b4a681fb7b0aa3679626f37bf "1002069"^^ . diff --git a/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/CrossStreamingSpec.scala b/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/CrossStreamingSpec.scala index 76d49685..25b1de82 100644 --- a/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/CrossStreamingSpec.scala +++ b/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/CrossStreamingSpec.scala @@ -62,21 +62,13 @@ class CrossStreamingSpec extends AnyWordSpec, Matchers, ScalaFutures, BeforeAndA ) private object TripleTests: - val files: Seq[(String, File)] = Seq[String]( - "weather.nt", "p2_ontology.nt", "nt-syntax-subm-01.nt", "rdf-star.nt", "rdf-star-blanks.nt" - ).map(name => ( - name, File(getClass.getResource("/triples/" + name).toURI) - )) + val files: Seq[(String, File)] = TestCases.triples val graphs: Map[String, Graph] = Map.from( files.map((name, f) => (name, RDFDataMgr.loadGraph(f.toURI.toString))) ) private object QuadTests: - val files: Seq[(String, File)] = Seq( - "nq-syntax-tests.nq", "weather-quads.nq" - ).map(name => ( - name, File(getClass.getResource("/quads/" + name).toURI) - )) + val files: Seq[(String, File)] = TestCases.quads val datasets: Map[String, DatasetGraph] = Map.from( files.map((name, f) => (name, RDFDataMgr.loadDatasetGraph(f.toURI.toString))) ) diff --git a/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/TestCases.scala b/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/TestCases.scala new file mode 100644 index 00000000..3a88af8f --- /dev/null +++ b/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/TestCases.scala @@ -0,0 +1,17 @@ +package eu.ostrzyciel.jelly.integration_tests + +import java.io.File + +object TestCases: + val triples: Seq[(String, File)] = Seq[String]( + "weather.nt", "p2_ontology.nt", "nt-syntax-subm-01.nt", "rdf-star.nt", "rdf-star-blanks.nt", + "rdf-stax-1-1-2.nt", "riverbench-assist-iot-weather-1-0-2.nt" + ).map(name => ( + name, File(getClass.getResource("/triples/" + name).toURI) + )) + + val quads: Seq[(String, File)] = Seq( + "nq-syntax-tests.nq", "weather-quads.nq", "nanopub-rdf-stax.nq" + ).map(name => ( + name, File(getClass.getResource("/quads/" + name).toURI) + )) diff --git a/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/io/IoSerDesSpec.scala b/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/io/IoSerDesSpec.scala index fd6e1163..144da0ed 100644 --- a/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/io/IoSerDesSpec.scala +++ b/integration-tests/src/test/scala/eu/ostrzyciel/jelly/integration_tests/io/IoSerDesSpec.scala @@ -2,6 +2,7 @@ package eu.ostrzyciel.jelly.integration_tests.io import eu.ostrzyciel.jelly.core.* import eu.ostrzyciel.jelly.core.proto.v1.RdfStreamOptions +import eu.ostrzyciel.jelly.integration_tests.TestCases import org.apache.jena.sys.JenaSystem import org.apache.pekko.actor.ActorSystem import org.scalatest.BeforeAndAfterAll @@ -21,18 +22,6 @@ class IoSerDesSpec extends AnyWordSpec, Matchers, ScalaFutures, BeforeAndAfterAl override def beforeAll(): Unit = JenaSystem.init() - val casesTriples: Seq[(String, File)] = Seq[String]( - "weather.nt", "p2_ontology.nt", "nt-syntax-subm-01.nt", "rdf-star.nt", "rdf-star-blanks.nt" - ).map(name => ( - name, File(getClass.getResource("/triples/" + name).toURI) - )) - - val casesQuads: Seq[(String, File)] = Seq( - "nq-syntax-tests.nq", "weather-quads.nq" - ).map(name => ( - name, File(getClass.getResource("/quads/" + name).toURI) - )) - val presets: Seq[(RdfStreamOptions, Int, String)] = Seq( (JellyOptions.smallGeneralized, 1, "small generalized"), (JellyOptions.smallRdfStar, 1_000_000, "small RDF-star"), @@ -114,7 +103,7 @@ class IoSerDesSpec extends AnyWordSpec, Matchers, ScalaFutures, BeforeAndAfterAl ) = f"${ser.name} serializer + ${des.name} deserializer" should { for (encOptions, decOptions, presetName) <- presetsUnsupported do - for (name, file) <- casesTriples do + for (name, file) <- TestCases.triples do s"not accept unsupported options (file $name, $presetName)" in { val model = ser.readTriplesW3C(FileInputStream(file)) val originalSize = summon[Measure[TMSer]].size(model) @@ -133,7 +122,7 @@ class IoSerDesSpec extends AnyWordSpec, Matchers, ScalaFutures, BeforeAndAfterAl } for (preset, size, presetName) <- presets do - for (name, file) <- casesTriples do + for (name, file) <- TestCases.triples do s"ser/des file $name with preset $presetName, frame size $size" in { val model = ser.readTriplesW3C(FileInputStream(file)) val originalSize = summon[Measure[TMSer]].size(model) @@ -153,7 +142,7 @@ class IoSerDesSpec extends AnyWordSpec, Matchers, ScalaFutures, BeforeAndAfterAl deserializedSize should be >= originalSize - 1 } - for (name, file) <- casesQuads do + for (name, file) <- TestCases.quads do s"ser/des file $name with preset $presetName, frame size $size" in { val ds = ser.readQuadsW3C(FileInputStream(file)) val originalSize = summon[Measure[TDSer]].size(ds)