Default value fix

mjakubowski84 · Aug 1, 2019 · 29c5512 · 29c5512
1 parent d890b3b
commit 29c5512
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/akka/src/main/scala/com/github/mjakubowski84/parquet4s/IndefiniteStreamParquetSink.scala b/akka/src/main/scala/com/github/mjakubowski84/parquet4s/IndefiniteStreamParquetSink.scala
@@ -15,7 +15,7 @@ private[parquet4s] object IndefiniteStreamParquetSink extends IOOps {
                                              maxChunkSize: Int,
                                              chunkWriteTimeWindow: FiniteDuration,
                                              buildChunkPath: ChunkPathBuilder[In] = ChunkPathBuilder.default,
-                                             preWriteTransformation: In => ToWrite = identity _,
+                                             preWriteTransformation: In => ToWrite = identity[In] _,
                                              postWriteSink: Sink[Seq[In], Mat] = Sink.ignore,
                                              options: ParquetWriter.Options = ParquetWriter.Options()
                                             ): Sink[In, Mat] = {