dataflow::sink::avro_ocf