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: rener.cas...@c6bank.com<mailto:breno.tamb...@c6bank.com>

[signature_1033755691]



Classificação: Interna


Classificação: Interna

Reply via email to