λ
Size: a a a
λ
AK
λ
AK
λ
λ
AK
D
λ
λ
λ
VC
D
DK
SP
https://scastie.scala-lang.org/s1rc0/8voEh1iGSciUISuQ1kngOw/2
Oℕ
λ
def avroFactory[A: ClassTag] = new AvroWriterFactory[A](new AvroBuilder[A]() {
override def createWriter(out: OutputStream): DataFileWriter[A] = {
val schema = ReflectData.get.getSchema(classTag[A].runtimeClass)
val datumWriter = new ReflectDatumWriter[A](schema)
val dataFileWriter = new DataFileWriter[A](datumWriter)
dataFileWriter.setCodec(CodecFactory.snappyCodec)
dataFileWriter.create(schema, out)
dataFileWriter
}
})
VS
λ