Skip to content

Commit

Permalink
Fix compile errors
Browse files Browse the repository at this point in the history
  • Loading branch information
kaklakariada committed Oct 9, 2023
1 parent 91755ff commit c94cda2
Showing 1 changed file with 2 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -500,6 +500,7 @@ class ParquetDataImporterIT extends BaseDataImporter {
private val parquetSchema = MessageTypeParser.parseMessageType(s"message test { $parquetColumn }")

def withWriter(block: (ParquetWriter[Group], MessageType) => Unit): ParquetChecker = {
val path = addFile()
val writer = getParquetWriter(path, parquetSchema, true)
block(writer, parquetSchema)
writer.close()
Expand Down Expand Up @@ -527,6 +528,7 @@ class ParquetDataImporterIT extends BaseDataImporter {
}

def withInputValues[T](values: List[T]): MultiParquetChecker = {
val path = addFile()
writeDataValues(values, path, parquetSchema)
this
}
Expand Down

0 comments on commit c94cda2

Please sign in to comment.