From 6c0f0f3f4c30ca0aebb3d5af221d6b121946d2a7 Mon Sep 17 00:00:00 2001 From: Robin Hillyard Date: Thu, 26 Mar 2026 19:57:37 -0400 Subject: [PATCH] Cosmetic fix for Codacy --- .../tableparser/parquet/ParquetTableParser.scala | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/parquet/src/main/scala/com/phasmidsoftware/tableparser/parquet/ParquetTableParser.scala b/parquet/src/main/scala/com/phasmidsoftware/tableparser/parquet/ParquetTableParser.scala index 237779d..6ed90cd 100644 --- a/parquet/src/main/scala/com/phasmidsoftware/tableparser/parquet/ParquetTableParser.scala +++ b/parquet/src/main/scala/com/phasmidsoftware/tableparser/parquet/ParquetTableParser.scala @@ -11,7 +11,7 @@ import org.apache.parquet.hadoop.ParquetReader import org.apache.parquet.hadoop.example.GroupReadSupport import org.apache.parquet.schema.MessageType import scala.reflect.ClassTag -import scala.util.Try +import scala.util.{Failure, Success, Try} /** * A TableBuilder for Parquet sources. @@ -62,7 +62,11 @@ abstract class ParquetTableParser[R <: Product : ClassTag] val schema: MessageType = readSchema(hadoopPath, conf) // Validate schema against the target case class before reading any rows - ParquetSchemaValidator.validate[Row](schema, helper).get + ParquetSchemaValidator.validate[Row](schema, helper) match { + case Failure(exception) => + throw exception + case Success(_) => + } // Build the Header from Parquet column names val header: Header = headerFromSchema(schema)