Function dataflow::sink::avro_ocf::avro_ocf

fn avro_ocf<G>(
    collection: Collection<G, (Option<Row>, Option<Row>)>, 
    id: GlobalId, 
    connector: AvroOcfSinkConnector, 
    desc: RelationDesc
) where
    G: Scope<Timestamp = Timestamp>,