Streamline parquet-avro with avro API

spotify · Feb 5, 2024 · 6f7f42d · 6f7f42d
1 parent 9c11122
commit 6f7f42d
Show file tree

Hide file tree

Showing 17 changed files with 1,130 additions and 1,254 deletions.
diff --git a/build.sbt b/build.sbt
@@ -1033,8 +1033,8 @@ lazy val `scio-parquet` = project
   .in(file("scio-parquet"))
   .dependsOn(
     `scio-core`,
+    `scio-avro` % "provided",
     `scio-tensorflow` % "provided",
-    `scio-avro` % Test,
     `scio-test` % "test->test"
   )
   .settings(commonSettings)

diff --git a/scio-core/src/main/scala/com/spotify/scio/coders/instances/JavaCoders.scala b/scio-core/src/main/scala/com/spotify/scio/coders/instances/JavaCoders.scala
@@ -37,7 +37,7 @@ import scala.util.{Failure, Success}
 private[coders] object VoidCoder extends AtomicCoder[Void] {
   override def encode(value: Void, outStream: OutputStream): Unit = ()
 
-  override def decode(inStream: InputStream): Void = ???
+  override def decode(inStream: InputStream): Void = null
 
   override def structuralValue(value: Void): AnyRef = AnyRef
 }