///|
fn main raise {
let schema = @schema.parse(
"{\"type\":\"record\",\"name\":\"Metric\",\"fields\":[{\"name\":\"name\",\"type\":\"string\"},{\"name\":\"value\",\"type\":\"double\"}]}",
)
let marker : Bytes = [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15]
let header = @avro_ocf.OcfHeader::new(schema, codec=Deflate, marker)
let writer = @avro_ocf.OcfWriter::new(header)
writer.append(
@codec.Record([
("name", @codec.String("requests")),
("value", @codec.Double(3.5)),
]),
)
let container = writer.finish()
let reader = @avro_ocf.OcfReader::open(container)
assert_true(reader.next() is Some(_))
assert_true(reader.next() is None)
println("OCF deflate roundtrip: ok")
}