record_query::value::avro
pub fn sink<W>(schema: &Schema, w: W, codec: Codec) -> Result<Sink<W>> where W: Write,