Dear Team,
i am trying to write bigquery table using pubsub message pull/suscribe .So
i am unable to convert *beam.collection []uint8/bytes* to
*beam.collection* *schema
type in go apachebeamsdk.*i am facing this issue :-*schema type must be
struct: []uint8*
*i am using this code: to read from pubsub message*
col := pubsubio.Read(s, project, *input, &pubsubio.ReadOptions{Subscription:
sub.ID()})
*i am using this code:- write in bigquery*
bigqueryio.Write(s, project, *output, out)
I request to all please help me to solve this problem.if any clarification
required please let me know and arrange a call.
Thankyou,
Abyakta bal
