There are ways you can manually force the coder here. However I would first
try to split up the KV creation into two operations. Have ProcessEvents
just create a PCollection, and then a following operation
to create the KV. Something like this:
input.apply(ParDo.of(New ProcessEvents()))
ProcessEvents receive as an input a Session object and créate a KV as an output
El El jue, 4 de abr de 2024 a la(s) 8:52 p.m., Reuven Lax via user <
user@beam.apache.org> escribió:
> There are some sharp edges unfortunately around auto-inference of KV
> coders and schemas. Is there a previous
There are some sharp edges unfortunately around auto-inference of KV coders
and schemas. Is there a previous PCollection of type SharedCoreEvent, or is
the SharedCoreEvent created in ProcessEvents?
On Thu, Apr 4, 2024 at 2:12 PM Ruben Vargas wrote:
> Hello guys
>
> I have a question, is it
Hello guys
I have a question, is it possible to use KV along with AutoValueSchema
objects? I'm having troubles when I try to use it together.
I have an object like the following
@AutoValue
@DefaultSchema(AutoValueSchema.class)
public abstract class SharedCoreEvent {
