Replacing a 'dash' from system hash code with '_' in order to yield a…

… valid spark table name.
SANSA-Stack · Mar 8, 2021 · 262b30c · 262b30c
1 parent 1b653aa
commit 262b30c
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/sansa-rdf/sansa-rdf-spark/src/main/scala/net/sansa_stack/rdf/spark/partition/package.scala b/sansa-rdf/sansa-rdf-spark/src/main/scala/net/sansa_stack/rdf/spark/partition/package.scala
@@ -55,7 +55,8 @@ package object partition extends Logging {
 
       // Create a table prefix for each partitioning of RDDs
       // TODO Encode partitioner hash into the name
-      val rddId = System.identityHashCode(rddOfTriples)
+      val rddSysHash = System.identityHashCode(rddOfTriples)
+      val rddId = if (rddSysHash < 0) "_" + rddSysHash else "" + rddSysHash
       val tableNaming: RdfPartitionStateDefault => String =
         partitionState => "rdd" + rddId + "_" + SQLUtils.encodeTablename(SQLUtils.createDefaultTableName(partitionState))