Hi guys,
I can't find a way to generic register a DoFn with ProcessElement like
parquetWriteFn - ProcessElement(ctx context.Context, _ int, iter
func(*interface{}) bool)
(https://github.com/apache/beam/blob/30a48f05cf2ee0eea0a304fea01eb40f323f9f3c/sdks/go/pkg/beam/io/parquetio/parquetio.go#L150)
I'm having this error:
```
bad input type
caused by:
encoding full type interface {}
bad type
caused by:
unencodable type interface {}
```
Any help on that will be greatly appreciated
Regards,
[cid:e17aa8cb-298b-41ba-b189-03e528e9c676]
Rener Castro
Data & Analytics
email: [email protected]<mailto:[email protected]>
[signature_1033755691]
Classificação: Interna
Classificação: Interna
