ParquetTypeMapper

com.phasmidsoftware.tableparser.parquet.ParquetTypeMapper

Maps Parquet primitive types to Scala types, taking into account both physical type and logical type annotation.

Attributes

Graph
Supertypes
class Object
trait Matchable
class Any
Self type

Members list

Value members

Concrete methods

def isOptional(pt: PrimitiveType): Boolean

Returns true if the Parquet column is OPTIONAL (i.e. nullable). Used during schema validation to check Option[T] compatibility.

Returns true if the Parquet column is OPTIONAL (i.e. nullable). Used during schema validation to check Option[T] compatibility.

Value parameters

pt

the Parquet PrimitiveType from the schema.

Attributes

Returns

true if the column repetition is OPTIONAL.

def mapType(pt: PrimitiveType): Either[ParquetParserException, Class[_]]

Maps a Parquet PrimitiveType to the corresponding Scala Class. Used during schema validation to verify type compatibility.

Maps a Parquet PrimitiveType to the corresponding Scala Class. Used during schema validation to verify type compatibility.

Value parameters

pt

the Parquet PrimitiveType from the schema.

Attributes

Returns

Right(Class[_]) if the type is supported, Left(ParquetParserException) if not.