def record()

in core/src/main/scala/com/gu/marley/AvroFile.scala [14:29]

• 10 lines of code
• 1 McCabe index (conditional complexity)

  def record(t: T) = serialisable.writableValue(t).asInstanceOf[Record]

  val schema = serialisable.schema.apply()

  val writer = new GenericDatumWriter[GenericRecord](schema)
  val dataFileWriter = new DataFileWriter[GenericRecord](writer)

  dataFileWriter.setCodec(CodecFactory.snappyCodec()).create(schema, file)

  def append(structs: Iterable[T]): Unit =
    structs.map(record).foreach(dataFileWriter.append)

  def close(): Unit = dataFileWriter.close()
}

object AvroFile {