Hey Rener, you should be able to register that function with
`register.DoFn3x1[context.Context, int, func(*interface{}) bool, error]`.
You would use DoFn3x1 because you have 3 inputs and 1 output in your
ProcessElement, and then the constraints are just the input types to your
ProcessElement function.
Thanks,
Danny
On Fri, Sep 16, 2022 at 7:44 AM Rener Pereira De Castro via user <
user@beam.apache.org> wrote:
> 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
> <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,
>
> *Rener Castro*
> *Data & Analytics*
> email: *rener.cas...@c6bank.com* <breno.tamb...@c6bank.com>
>
> [image: signature_1033755691]
>
>
> Classificação: Interna
>
> Classificação: Interna
>
