We need some way for
a) To extract fields from incoming avro/protobuf methods into columns
b) Define fields in outgoing avro/protobuf messages from columns
A couple of possible approaches:
a) Provide a set of functions like we do for JSON, e.g. avro_get_int(...), avro_create_message()
b) Provide a custom operator to do the mapping from/to avro/protobuf
We need some way for a) To extract fields from incoming avro/protobuf methods into columns b) Define fields in outgoing avro/protobuf messages from columns
A couple of possible approaches: a) Provide a set of functions like we do for JSON, e.g. avro_get_int(...), avro_create_message() b) Provide a custom operator to do the mapping from/to avro/protobuf