avro encode/decode single record

gistfile1.txt

  val entityMetadataSchema = SchemaBuilder
    .record("entityMetadata")
    .fields()
    .name("relatedLookupRecords").`type`().array().items(Schema.create(Schema.Type.STRING)).noDefault()
    .endRecord()

  def serialize(x: GenericRecord, s: Schema): Array[Byte] = {
    val baos = new ByteArrayOutputStream()
    val fw = new DataFileWriter[GenericRecord](new GenericDatumWriter[GenericRecord]())
    fw.create(s, baos)
    fw.append(x)
    fw.close()
    baos.toByteArray
  }

  def deserialize(x: Array[Byte], s: Schema): GenericRecord = {
    val sbai = new SeekableByteArrayInput(x)
    val dr = new DataFileReader[GenericRecord](sbai, new GenericDatumReader[GenericRecord](s))
    val record = dr.next()
    dr.close()
    record
  }