fix csv extension

dszakallas · dszakallas · commit 638b24daf339 · 2021-12-13T17:52:08.000+01:00
diff --git a/src/main/scala/ldbc/snb/datagen/io/raw/package.scala b/src/main/scala/ldbc/snb/datagen/io/raw/package.scala
@@ -80,7 +80,7 @@ package object raw {
           s"${compression.getExtension}.${sink.format}"
         )
       }
-      case Csv => (csvRecordOutputStream(_: Path, writeContext), sink.format.toString)
+      case Csv => (csvRecordOutputStream(_: Path, writeContext), s".${sink.format.toString}")
       case x   => throw new UnsupportedOperationException(s"Raw serializer not implemented for format ${x}")
     }
     val files =

Original file line number	Diff line number	Diff line change
`@@ -80,7 +80,7 @@ package object raw {`
`80`	`80`	`s"${compression.getExtension}.${sink.format}"`
`81`	`81`	`)`
`82`	`82`	`}`
`83`		`- case Csv => (csvRecordOutputStream(_: Path, writeContext), sink.format.toString)`
	`83`	`+ case Csv => (csvRecordOutputStream(_: Path, writeContext), s".${sink.format.toString}")`
`84`	`84`	`case x => throw new UnsupportedOperationException(s"Raw serializer not implemented for format ${x}")`
`85`	`85`	`}`
`86`	`86`	`val files =`