RDF-STaX: update stream type IRIs

Issue: RiverBench/RiverBench#55
RiverBench · Oct 29, 2023 · 6b533c1 · 6b533c1
1 parent 413cfb9
commit 6b533c1
Show file tree

Hide file tree

Showing 2 changed files with 20 additions and 17 deletions.
diff --git a/src/main/scala/util/MetadataReader.scala b/src/main/scala/util/MetadataReader.scala
@@ -11,23 +11,6 @@ import org.apache.jena.vocabulary.RDF
 import java.nio.file.Path
 import scala.jdk.CollectionConverters.*
 
-enum ElementType(val name: String):
-  case Graph extends ElementType("graph")
-  case Dataset extends ElementType("dataset")
-  case Triple extends ElementType("triple")
-  case Quad extends ElementType("quad")
-
-enum StreamType(val iriName: String, val isFlat: Boolean, val elementType: ElementType):
-  lazy val iri = RdfUtil.pStax + iriName
-
-  case Graph extends StreamType("rdfGraphStream", false, ElementType.Graph)
-  case SubjectGraph extends StreamType("rdfSubjectGraphStream", false, ElementType.Graph)
-  case Dataset extends StreamType("rdfDatasetStream", false, ElementType.Dataset)
-  case NamedGraph extends StreamType("rdfNamedGraphStream", false, ElementType.Dataset)
-  case TimestampedNamedGraph extends StreamType("timestampedRdfNamedGraphStream", false, ElementType.Dataset)
-  case Triple extends StreamType("flatRdfTripleStream", true, ElementType.Triple)
-  case Quad extends StreamType("flatRdfQuadStream", true, ElementType.Quad)
-
 case class MetadataInfo(
   identifier: String = "",
   description: String = "",

diff --git a/src/main/scala/util/StreamType.scala b/src/main/scala/util/StreamType.scala
@@ -0,0 +1,20 @@
+package io.github.riverbench.ci_worker
+package util
+
+
+enum ElementType(val name: String):
+  case Graph extends ElementType("graph")
+  case Dataset extends ElementType("dataset")
+  case Triple extends ElementType("triple")
+  case Quad extends ElementType("quad")
+
+enum StreamType(val iriName: String, val isFlat: Boolean, val elementType: ElementType):
+  lazy val iri = RdfUtil.pStax + iriName
+
+  case Graph extends StreamType("graphStream", false, ElementType.Graph)
+  case SubjectGraph extends StreamType("subjectGraphStream", false, ElementType.Graph)
+  case Dataset extends StreamType("datasetStream", false, ElementType.Dataset)
+  case NamedGraph extends StreamType("namedGraphStream", false, ElementType.Dataset)
+  case TimestampedNamedGraph extends StreamType("timestampedNamedGraphStream", false, ElementType.Dataset)
+  case Triple extends StreamType("flatTripleStream", true, ElementType.Triple)
+  case Quad extends StreamType("flatQuadStream", true, ElementType.Quad)