in parquet/src/main/scala/magnolify/parquet/ParquetType.scala [92:117]
implicit def apply[T](implicit f: ParquetField[T], pa: ParquetArray): ParquetType[T] =
ParquetType(CaseMapper.identity, MagnolifyParquetProperties.Default)
def apply[T](
cm: CaseMapper
)(implicit f: ParquetField[T], pa: ParquetArray): ParquetType[T] =
ParquetType[T](cm, MagnolifyParquetProperties.Default)(f, pa)
def apply[T](
conf: Configuration
)(implicit f: ParquetField[T], pa: ParquetArray): ParquetType[T] =
ParquetType[T](
CaseMapper.identity, {
val WriteAvroCompatibleArraysOpt =
Option(conf.get(MagnolifyParquetProperties.WriteAvroCompatibleArrays)).map(_.toBoolean)
val writeMetadataOpt = Option(
conf.get(MagnolifyParquetProperties.WriteAvroSchemaToMetadata)
).map(_.toBoolean)
new MagnolifyParquetProperties {
override def WriteAvroCompatibleArrays: Boolean =
WriteAvroCompatibleArraysOpt.getOrElse(super.WriteAvroCompatibleArrays)
override def writeAvroSchemaToMetadata: Boolean =
writeMetadataOpt.getOrElse(super.writeAvroSchemaToMetadata)
}
}